diff --git a/components/orchestration/orchestrator.py b/components/orchestration/orchestrator.py index 3d94a7b..8db0469 100644 --- a/components/orchestration/orchestrator.py +++ b/components/orchestration/orchestrator.py @@ -57,6 +57,11 @@ class Orchestrator: 'last_switch': datetime.now()} def setup_msg_queues(self): + """ + Setup the message queues for communicating with vehicles and traffic lights. + A receiving and a sending queue for vehicles. + A receiving queue for traffic lights. + """ # spawn the vehicle related message broker channels for vin in self.vins: daf_channel = MBWrapper(exchange_name='vehicle_daf_{}'.format(vin), callback=self.handle_daf_receive)