#NEWLINE# def proxy( self , reset_master_mock = False , **kwargs ) : #NEWLINE# #INDENT# proxy_kwargs = dict ( topic = self . topic , exchange = self . exchange , url = self . broker_url , type_handlers = { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } ) #NEWLINE# proxy_kwargs . update ( kwargs ) #NEWLINE# p = proxy . Proxy ( ** proxy_kwargs ) #NEWLINE# if proxy_kwargs : #NEWLINE# #INDENT# self . resetMasterMock ( ) #NEWLINE# #UNINDENT# return p