+
+class Queue(object):
+ def __init__(self, connection, queue_name):
+ self.connection = connection
+ self.queue_name = queue_name
+ self.connection.channel.queue_declare(queue=self.queue_name)
+
+ def receive(self, timeout=0):
+ return self.connection.receive(queues=[self.queue_name], timeout=timeout)
+