From cd36b6c22ca1e6447e01fa2e1000d9c79d5288d0 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Krist=C3=B3f=20T=C3=B3th?= Date: Fri, 13 Apr 2018 16:35:30 +0200 Subject: [PATCH] Refactor ServerUplinkConnector to use new serializers --- lib/tfw/networking/event_handlers/server_connector.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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):