#NEWLINE# def _purge( self , queue ) : #NEWLINE# #INDENT# size = self . _size ( queue ) #NEWLINE# if ( queue in self . _fanout_queues ) : #NEWLINE# #INDENT# self . _get_broadcast_cursor ( queue ) . purge ( ) #NEWLINE# #UNINDENT# else : #NEWLINE# #INDENT# self . messages . remove ( { #NEWLINE# #INDENT# 'queue' : queue , #NEWLINE# #UNINDENT# } ) #NEWLINE# #UNINDENT# return size