#NEWLINE# def run( self ) : #NEWLINE# #INDENT# with self . mb as mb : #NEWLINE# #INDENT# launched = False #NEWLINE# while ( not launched ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# ts = beem . load . TrackingSender ( 'localhost' , mb . port , ( 'ts_' + mb . label ) ) #NEWLINE# launched = True #NEWLINE# #UNINDENT# except : #NEWLINE# #INDENT# time . sleep ( 0.5 ) #NEWLINE# #UNINDENT# #UNINDENT# if self . mb . auth : #NEWLINE# #INDENT# cid = self . mb . auth . split ( ':' ) [ 0 ] #NEWLINE# gen = beem . msgs . createGenerator ( cid , self . options ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# gen = beem . msgs . createGenerator ( self . mb . label , self . options ) #NEWLINE# #UNINDENT# ts . run ( gen ) #NEWLINE# self . stats = ts . stats ( )