def start_filter(app, conn, filter, limit=None, timeout=1.0, ack_messages=False, tasks=None, queues=None, callback=None, forever=False, on_declare_queue=None, consume_from=None, state=None, accept=None, **kwargs):
 return Filterer(app, conn, filter, limit=limit, timeout=timeout, ack_messages=ack_messages, tasks=tasks, queues=queues, callback=callback, forever=forever, on_declare_queue=on_declare_queue, consume_from=consume_from, state=state, accept=accept, **kwargs).start()

def start_filter ( app , conn , filter , limit = None , timeout = 1.0 , ack_messages = False , tasks = None , queues = None , callback = None , forever = False , on_declare_queue = None , consume_from = None , state = None , accept = None , ** kwargs ) : return Filterer ( app , conn , filter , limit = limit , timeout = timeout , ack_messages = ack_messages , tasks = tasks , queues = queues , callback = callback , forever = forever , on_declare_queue = on_declare_queue , consume_from = consume_from , state = state , accept = accept , ** kwargs ) . start ( )
filter tasks .