#NEWLINE# def _collect_replies( self , conn , channel , ticket , * args , **kwargs ) : #NEWLINE# #INDENT# kwargs . setdefault ( 'timeout' , self . default_timeout ) #NEWLINE# if ( ( 'limit' not in kwargs ) and self . agent ) : #NEWLINE# #INDENT# kwargs [ 'limit' ] = self . agent . get_default_scatter_limit ( ) #NEWLINE# #UNINDENT# if ( ( 'ignore_timeout' not in kwargs ) and ( not kwargs . get ( 'limit' , None ) ) ) : #NEWLINE# #INDENT# kwargs . setdefault ( 'ignore_timeout' , False ) #NEWLINE# #UNINDENT# return collect_replies ( conn , self , self . get_reply_queue ( ticket ) , * args , ** kwargs )