#NEWLINE# def run( self , generator , qos = 1 ) : #NEWLINE# #INDENT# with self . mb as mb : #NEWLINE# #INDENT# launched = False #NEWLINE# while ( not launched ) : #NEWLINE# #INDENT# try : #NEWLINE# #INDENT# self . ts = beem . load . TrackingSender ( 'localhost' , mb . port , ( 'ts_' + generator . label ) ) #NEWLINE# launched = True #NEWLINE# #UNINDENT# except : #NEWLINE# #INDENT# time . sleep ( 0.5 ) #NEWLINE# #UNINDENT# #UNINDENT# self . ts . run ( generator , qos )