Wenn eine Message beim Server des Routers eintrifft, übergibt dieser sie dem worker:
Code: Alles auswählen
# socket parameter not required: registered messages are sent to the clients, which did register for message ids
else: worker.proxy.send_extern(message_id,message)Code: Alles auswählen
def route(self,message_with_sock_dictionary): # normal routing
sock_dictionary = message_with_sock_dictionary[0]
message = message_with_sock_dictionary[1][1]
for sock in sock_dictionary: sock.sendall(message)