def get(self, queue, no_ack=False):
        global QUEUES
        if not queue in QUEUES or not QUEUES[queue].size():
            return None
        (message_data, content_type, content_encoding) = QUEUES[queue].pop()
        message = Message(backend=self, body=message_data,
                          content_type=content_type,
                          content_encoding=content_encoding)
        message.result = True
        LOG.debug(_('Getting from %(queue)s: %(message)s') % locals())
        return message
dataset/ETHPy150Open nii-cloud/dodai-compute/nova/fakerabbit.py/Backend.get/original