#NEWLINE# def _reconnect_consumer_callbacks( self ) : #NEWLINE# #INDENT# for ( queue , consumers ) in self . consumers . items ( ) : #NEWLINE# #INDENT# for consumer in consumers : #NEWLINE# #INDENT# self . _reconnect_consumer_callback ( queue , consumer )