#NEWLINE# def get_reply_event( self , correlation_id ) : #NEWLINE# #INDENT# reply_event = ConsumeEvent ( self . queue_consumer , correlation_id ) #NEWLINE# self . _reply_events [ correlation_id ] = reply_event #NEWLINE# return reply_event