tormakris/bigchungusdata
1
0
Fork 0
Code Pull Requests Releases Activity

fix json in zmq

Browse Source
This commit is contained in:
Torma Kristóf 2021-04-25 12:33:49 +02:00
parent 9af55c9b76
commit ee7bef7295
1 changed files with 1 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
zmq/publisher.py
View File

@ -1,7 +1,4 @@
#!/usr/bin/env python3 #!/usr/bin/env python3
import itertools
import sys
import zmq import zmq
@ -10,7 +7,7 @@ socket = context.socket(zmq.PUB)
socket.bind("tcp://127.0.0.1:5559") socket.bind("tcp://127.0.0.1:5559")
n = 10 n = 10
msg_body = "a" * n msg_body = "\"" + "a" * n + "\""
try: try:
while True: while True:
socket.send_string(f"test {msg_body}") socket.send_string(f"test {msg_body}")