zenon/dse-assignment
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

update doc

Browse Source
This commit is contained in:
Marco Zeisler 2021-06-11 17:08:48 +02:00
parent fd77446af7
commit b248c41963
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
components/orchestration/orchestrator.py
View File

@ -57,6 +57,11 @@ class Orchestrator:
'last_switch': datetime.now()} 'last_switch': datetime.now()}
def setup_msg_queues(self): 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 # spawn the vehicle related message broker channels
for vin in self.vins: for vin in self.vins:
daf_channel = MBWrapper(exchange_name='vehicle_daf_{}'.format(vin), callback=self.handle_daf_receive) daf_channel = MBWrapper(exchange_name='vehicle_daf_{}'.format(vin), callback=self.handle_daf_receive)