def __init__(self, port):
    self.port = port
    self.ctx = zmq.Context()
    self.sock = self.ctx.socket(zmq.DEALER)
    self.sock.connect('tcp://127.0.0.1:{}'.format(self.port))
    self.counter = 0
    self.prefix = self.REQ_PREFIX.pack((os.getpid() % 65536), random.randrange(65536))
def __init__(self, port):
    self.port = port
    self.ctx = zmq.Context()
    self.sock = self.ctx.socket(zmq.DEALER)
    self.sock.connect('tcp://127.0.0.1:{}'.format(self.port))
    self.counter = 0
    self.prefix = self.REQ_PREFIX.pack((os.getpid() % 65536), random.randrange(65536))