'Constructor for KombuQueue
url:        http://kombu.readthedocs.org/en/latest/userguide/connections.html#urls
maxsize:    an integer that sets the upperbound limit on the number of
items that can be placed in the queue.'

def __init__(self, name, url='amqp://', maxsize=0, lazy_limit=True):

    self.name = name
    self.conn = Connection(url)
    self.queue = self.conn.SimpleQueue(self.name, no_ack=True, serializer='umsgpack')
    self.maxsize = maxsize
    self.lazy_limit = lazy_limit
    if (self.lazy_limit and self.maxsize):
        self.qsize_diff_limit = int((self.maxsize * 0.1))
    else:
        self.qsize_diff_limit = 0
    self.qsize_diff = 0
