#NEWLINE# def test_queue_purge( self , n = 'test_queue_purge' ) : #NEWLINE# #INDENT# class PurgeChannel ( virtual . Channel ) : #NEWLINE# #INDENT# purged = [ ] #NEWLINE# def _purge( self , queue ) : #NEWLINE# #INDENT# self . purged . append ( queue ) #NEWLINE# #UNINDENT# #UNINDENT# c = PurgeChannel ( self . channel . connection ) #NEWLINE# c . exchange_declare ( n ) #NEWLINE# c . queue_declare ( self ) #NEWLINE# c . queue_bind ( n , n , n ) #NEWLINE# c . queue_purge ( n ) #NEWLINE# self . assertIn ( n , c . purged )