mirror of
				https://github.com/avatao-content/baseimage-tutorial-framework
				synced 2025-11-04 11:52:54 +00:00 
			
		
		
		
	Refactor ServerUplinkConnector to use new serializers
This commit is contained in:
		@@ -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):
 | 
			
		||||
 
 | 
			
		||||
		Reference in New Issue
	
	Block a user