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