#NEWLINE# def get_consumers( self , Consumer , channel ) : #NEWLINE# #INDENT# ' Kombu callback to set up consumers.\n\n        Called after any (re)connection to the broker.\n        ' #NEWLINE# _log . debug ( 'setting up consumers %s' , self ) #NEWLINE# for provider in self . _providers : #NEWLINE# #INDENT# callbacks = [ self . _on_message , provider . handle_message ] #NEWLINE# consumer = Consumer ( queues = [ provider . queue ] , callbacks = callbacks , accept = self . accept ) #NEWLINE# consumer . qos ( prefetch_count = self . prefetch_count ) #NEWLINE# self . _consumers [ provider ] = channel #NEWLINE# #UNINDENT# return self . _consumers . values ( )