#NEWLINE# def empty_topic( self , topic ) : #NEWLINE# #INDENT# 'Empty all the queued messages for an existing topic.' #NEWLINE# nsq . assert_valid_topic_name ( self ) #NEWLINE# return self . http_post ( '/empty_topic' , fields = { #NEWLINE# #INDENT# 'topic' : topic , #NEWLINE# #UNINDENT# } )