#NEWLINE# def _ProcessReply( self , stream ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# ( msg_type , tag ) = ThriftMuxMessageSerializerSink . ReadHeader ( stream ) #NEWLINE# if ( ( tag == 1 ) and ( msg_type == MessageType . Rping ) ) : #NEWLINE# #INDENT# self . _OnPingResponse ( msg_type , msg_type ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# if ( tag != 0 ) : #NEWLINE# #INDENT# self . _ProcessTaggedReply ( tag , stream ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . _log . error ( ( 'Unexpected message, msg_type = %d, tag = %d' % ( msg_type , tag ) ) ) #NEWLINE# #UNINDENT# #UNINDENT# #UNINDENT# except Exception : #NEWLINE# #INDENT# self . _log . exception ( 'Exception processing reply message.' )