def _deliver(self, message, queue):
        if not queue:
            raise KeyError(
                'Received message without destination queue: {0}'.format(
                    message))
        try:
            callback = self._callbacks[queue]
        except __HOLE__:
            logger.warn(W_NO_CONSUMERS, queue)
            self._reject_inbound_message(message)
        else:
            callback(message)
dataset/ETHPy150Open celery/kombu/kombu/transport/virtual/__init__.py/Transport._deliver