

def send(self, ident, data):
    try:
        data = self.pickler.dumps(data)
    except TypeError as exc:
        raise self.pickler.PickleError(exc)
    message = Message(data=(REPLY_PREFIX + data))
    message.receive_hook.messaging.send_message(ident, message)

dataset/ETHPy150Open dsiroky/snakemq/snakemq/rpc.py RpcServer.send/VarMisuse@61/70 `self`->`message`