

def on_recv(self, dummy_conn_id, ident, message):
    try:
        params = self.pickler.loads(message.data[len(REQUEST_PREFIX):])
    except self.pickler.PickleError as exc:
        self.log.error(('on_recv unpickle: %r' % exc))
        return
    cmd = params['command']
    if (cmd in ('call', 'signal')):
        thr = threading.Thread(target=self.call_method, name=('mqrpc_call;%s;%s' % (params['object'], params['method'])), args=(ident, params))
        thr.setDaemon(True)
        thr.start()

dataset/ETHPy150Open dsiroky/snakemq/snakemq/rpc.py RpcServer.on_recv/original