mirror of
https://github.com/avatao-content/baseimage-tutorial-framework
synced 2024-11-09 01:27:17 +00:00
Fix code formatting
This commit is contained in:
parent
26c6c5d1e6
commit
6b23b863ed
@ -19,7 +19,7 @@ class ServerDownlinkConnector(ZMQConnectorBase):
|
||||
super(ServerDownlinkConnector, self).__init__(zmq_context)
|
||||
self._zmq_sub_socket = self._zmq_context.socket(zmq.SUB)
|
||||
self._zmq_sub_socket.connect(f'tcp://localhost:{TFWENV.PUBLISHER_PORT}')
|
||||
self._zmq_sub_socket.setsockopt(zmq.RCVHWM,0)
|
||||
self._zmq_sub_socket.setsockopt(zmq.RCVHWM, 0)
|
||||
self._zmq_sub_stream = ZMQStream(self._zmq_sub_socket)
|
||||
|
||||
self.subscribe = partial(self._zmq_sub_socket.setsockopt_string, zmq.SUBSCRIBE)
|
||||
@ -41,7 +41,7 @@ class ServerUplinkConnector(ZMQConnectorBase):
|
||||
super(ServerUplinkConnector, self).__init__(zmq_context)
|
||||
self._zmq_push_socket = self._zmq_context.socket(zmq.PUSH)
|
||||
self._zmq_push_socket.connect(f'tcp://localhost:{TFWENV.RECEIVER_PORT}')
|
||||
self._zmq_push_socket.setsockopt(zmq.SNDHWM,0)
|
||||
self._zmq_push_socket.setsockopt(zmq.SNDHWM, 0)
|
||||
|
||||
def send_to_eventhandler(self, message):
|
||||
"""
|
||||
|
Loading…
Reference in New Issue
Block a user