#NEWLINE# def on_consume_ready( self , connection , channel , consumers , **kwargs ) : #NEWLINE# #INDENT# ' Kombu callback when consumers are ready to accept messages.\n\n        Called after any (re)connection to the broker.\n        ' #NEWLINE# if ( not self . _consumers_ready . ready ( ) ) : #NEWLINE# #INDENT# _log . debug ( 'consumer started %s' , self ) #NEWLINE# self . _consumers_ready . send ( None ) #NEWLINE# #UNINDENT# for provider in connection . _providers : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# callback = provider . on_consume_ready #NEWLINE# #UNINDENT# except AttributeError : #NEWLINE# #INDENT# pass #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# callback ( )