def on_message_ready(self, channel, message, queue):
        if not queue or self._callbacks not in queue:
            raise KeyError(
                'Message for queue {0!r} without consumers: {1}'.format(
                    queue, message))
        self._callbacks[queue](message)
dataset/ETHPy150Open celery/kombu/kombu/transport/virtual/__init__.py/Transport.on_message_ready/swapped operands of `not in`