#NEWLINE# def __init__( self , queue , url , manager = '_default_' ) : #NEWLINE# #INDENT# self . queue = queue #NEWLINE# self . url = url #NEWLINE# self . manager = url #NEWLINE# self . active = True #NEWLINE# self . exchange = get_exchange ( url , manager , { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } ) #NEWLINE# self . messages = [ ]