#NEWLINE# @ inlineCallbacks #NEWLINE# def onJoin( self , details ) : #NEWLINE# #INDENT# counter = 0 #NEWLINE# while True : #NEWLINE# #INDENT# print ( 'publish: com.myapp.topic1' , details ) #NEWLINE# ( yield self . publish ( 'com.myapp.topic1' , counter ) ) #NEWLINE# counter += 1 #NEWLINE# ( yield sleep ( 1 ) )