#NEWLINE# def Consumer( self , channel , **kwargs ) : #NEWLINE# #INDENT# 'Returns a :class:`kombu.Consumer` instance for this Actor' #NEWLINE# kwargs . setdefault ( 'no_ack' , self . no_ack ) #NEWLINE# return Consumer ( channel , self . get_queues ( ) , callbacks = [ channel . on_message ] , ** kwargs )