<gh_stars>1-10
import zmq
import time
context = zmq.Context()
socket = context.socket(zmq.XSUB)
socket.connect("tcp://127.0.0.1:5556")
socket.send(b'\x01A')
work_item = socket.recv_string()
print(work_item)

import zmq
import time
context = zmq.Context()
socket = context.socket(zmq.XSUB)
socket.connect("tcp://127.0.0.1:5556")
socket.send(b'\x01A')
work_item = socket.recv_string()
print(work_item)