zf = ZmqFactory()

    addr = 'tcp://*:%s' % port

    log.info('creating zmq endpoint at %r', addr)

    e = ZmqEndpoint('bind', addr)

    class Pull(ZmqPullConnection):

        def onPull(self, message):

            with stats.setAttr.time():

                # todo: new compressed protocol where you send all URIs up

                # front and then use small ints to refer to devices and

                # attributes in subsequent requests.

                client, clientSession, settings, sendTime = parseJsonMessage(message[0])

class TwistedZmqClient(object):

    def __init__(self, service):

        zf = ZmqFactory()

        e = ZmqEndpoint('connect', 'tcp://%s:%s' % (service.host, service.port))

        class Push(ZmqPushConnection):

        self.conn = Push(zf, e)

    def send(self, clientid, levellist):

        self.conn.push(json.dumps({'clientid': clientid, 'levellist': levellist}))

def outputlevels(levellist,twisted=0,clientid=_id):