def METHOD_NAME(self, message):
    # Events with callbacks are very tricky to handle across hosts
    # Here in the receiving end we set up a local callback that preserves
    # the callback host and id from the sender
    remote_callback = message.get('callback')
    remote_host_id = message.get('host_id')
    if remote_callback is not None and len(remote_callback) == 3:
        callback = partial(self._return_callback, remote_host_id,
                           *remote_callback)
    else:
        callback = None
    super(PubSubManager, self).emit(message['event'], message['data'],
                                    namespace=message.get('namespace'),
                                    room=message.get('room'),
                                    skip_sid=message.get('skip_sid'),
                                    callback=callback)