#NEWLINE# def handle_sub( self , command , opts , topics , endpoint , timeout , ssh_server , ssh_keyfile ) : #NEWLINE# #INDENT# consumer = CircusConsumer ( topics , endpoint = endpoint ) #NEWLINE# for ( topic , msg ) in consumer : #NEWLINE# #INDENT# print ( ( '%s: %s' % ( opts , msg ) ) ) #NEWLINE# #UNINDENT# return 0