mirror of
https://github.com/avatao-content/baseimage-tutorial-framework
synced 2024-11-22 17:11:32 +00:00
Fix EventHandlerConnector dying painfully on keyless messages
This commit is contained in:
parent
095c818a36
commit
fda242d263
@ -35,6 +35,5 @@ class EventHandlerConnector(EventHandlerDownlinkConnector, EventHandlerUplinkCon
|
|||||||
self._zmq_pull_stream.on_recv(callback)
|
self._zmq_pull_stream.on_recv(callback)
|
||||||
|
|
||||||
def send_message(self, message: dict, key: str = None):
|
def send_message(self, message: dict, key: str = None):
|
||||||
if not key:
|
if not key: key = message.get('key', '')
|
||||||
key = message['key']
|
|
||||||
self._zmq_pub_socket.send_multipart(serialize_all(key, message))
|
self._zmq_pub_socket.send_multipart(serialize_all(key, message))
|
||||||
|
Loading…
Reference in New Issue
Block a user