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"):
            # method must not block link loop
            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