@@ -0,0 +1,565 @@
+import amqp%0Afrom contextlib import closing%0A%0A%0Adef __get_channel(connection):%0A    return connection.channel()%0A%0Adef __get_message_from_queue(channel, queue):%0A    channel.basic_get(queue=queue)%0A%0Adef get_message(queue):%0A    %22%22%22 Get the first message from a queue.%0A%0A    :param queue: The name of the queue from which to get the message.%0A%0A    Usage::%0A%0A    %3E%3E%3E from utils import get_message%0A    %3E%3E%3E get_message('queue')%0A%0A    %22%22%22%0A    with closing(amqp.Connection()) as connection:%0A        channel = __get_channel(connection)%0A        __get_message_from_queue(channel, queue)%0A

Add get_message module