#NEWLINE# def sieged( ) : #NEWLINE# #INDENT# t = time . time ( ) #NEWLINE# while True : #NEWLINE# #INDENT# n = wait ( 'bam' ) #NEWLINE# if ( ( n % 10000 ) == 0 ) : #NEWLINE# #INDENT# log . info ( str ( n ) ) #NEWLINE# if ( n == 50000 ) : #NEWLINE# #INDENT# delt = ( time . time ( ) - t ) #NEWLINE# log . debug ( '50,000 messages in {0:.3f}s {1:.1f}/s)' , delt , ( 50000 / delt ) ) #NEWLINE# quickstop ( )