#NEWLINE# def get_or_create_connection( self , producer ) : #NEWLINE# #INDENT# client = self . connection_factory ( self . address , 1 , 0 , producer . consumer_factory , producer ) #NEWLINE# server = self . connection_factory ( ( '127.0.0.1' , 46387 ) , 1 , 0 , producer . server_consumer , producer ) #NEWLINE# client . connection_made ( DummyTransport ( client , server ) ) #NEWLINE# server . connection_made ( DummyTransport ( producer , client ) ) #NEWLINE# return client