Remove message scope during routing

This commit is contained in:
Kristóf Tóth 2019-07-04 15:55:23 +02:00
parent 80e42a4091
commit dc62508a7b

View File

@ -54,7 +54,7 @@ class TFWRouter:
self.send_to_websockets = send_to_websockets
def route(self, message):
scope = Scope(message.get('scope', 'zmq'))
scope = Scope(message.pop('scope', 'zmq'))
routing_table = {
Scope.ZMQ: self.send_to_zmq,