#NEWLINE# def Consumer( self , channel , **kwargs ) : #NEWLINE# #INDENT# return ModelConsumer ( channel , self . exchange , callbacks = [ self . on_message ] , sigmap = self . sigmap , model = self . model , queues = [ self . get_scatter_queue ( ) , self . get_rr_queue ( ) ] , ** kwargs )