def itermessages(conn, channel, queue, limit=1, timeout=None, callbacks=None, **kwargs):
 return drain_consumer(conn.Consumer(queues=[queue], channel=channel, **kwargs), limit=limit, timeout=timeout, callbacks=callbacks)

def itermessages ( conn , channel , queue , limit = 1 , timeout = None , callbacks = None , ** kwargs ) : return drain_consumer ( conn . Consumer ( queues = [ queue ] , channel = channel , ** kwargs ) , limit = limit , timeout = timeout , callbacks = callbacks )
iterator over messages .