#NEWLINE# def on_message( self , headers , message ) : #NEWLINE# #INDENT# StatsListener . on_message ( self , headers , message ) #NEWLINE# self . message_list . append ( ( headers , message ) ) #NEWLINE# with self . message_condition : #NEWLINE# #INDENT# self . message_received = True #NEWLINE# self . message_condition . notify ( )