fatih

import os
import sys
import threading

import zmq

def worker(identity, wurl):
    ctx = zmq.Context.instance()
    s = ctx.socket(zmq.REP)
    s.identity = identity