'Get message by direct access (synchronous).'

def basic_get(self, queue, no_ack=False, **kwargs):

    try:
        message = self.Message(self._get(queue), channel=self)
        if (not no_ack):
            self.qos.append(message, message.delivery_tag)
        return message
    except Empty:
        pass
