diff --git a/lib/tfw/networking/event_handlers/server_connector.py b/lib/tfw/networking/event_handlers/server_connector.py index 74c2316..fa98f21 100644 --- a/lib/tfw/networking/event_handlers/server_connector.py +++ b/lib/tfw/networking/event_handlers/server_connector.py @@ -6,7 +6,7 @@ from functools import partial import zmq from zmq.eventloop.zmqstream import ZMQStream -from tfw.networking import serialize_all +from tfw.networking import serialize_tfw_msg from tfw.networking import ZMQConnectorBase from tfw.config import TFWENV @@ -35,7 +35,7 @@ class ServerUplinkConnector(ZMQConnectorBase): self.send(message) def send(self, message): - self._zmq_push_socket.send_multipart(serialize_all(message['key'], message)) + self._zmq_push_socket.send_multipart(serialize_tfw_msg(message)) class ServerConnector(ServerUplinkConnector, ServerDownlinkConnector):