bugfix
This commit is contained in:
parent
521498a18d
commit
0aeb1df05f
@ -38,7 +38,7 @@ async def zmq_subcribe(special_key: str, zmq_url='tcp://127.0.0.1:5555', callbac
|
|||||||
ctx.term()
|
ctx.term()
|
||||||
return content
|
return content
|
||||||
|
|
||||||
async def zmq_publish(key, content, zmq_url):
|
async def zmq_publish(key, content, zmq_url='tcp://127.0.0.1:5555'):
|
||||||
ctx = Context()
|
ctx = Context()
|
||||||
sock = ctx.socket(zmq.PUB)
|
sock = ctx.socket(zmq.PUB)
|
||||||
monitor = sock.get_monitor_socket()
|
monitor = sock.get_monitor_socket()
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user