#NEWLINE# def onMessage( self , msg , binary ) : #NEWLINE# #INDENT# if ( self . factory . endCaseId is None ) : #NEWLINE# #INDENT# self . factory . endCaseId = int ( msg ) #NEWLINE# self . log . info ( 'Ok, will run {case_count} cases' , case_count = self . factory . endCaseId ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . sendMessage ( msg , msg )