#NEWLINE# def test_revive( self , n = 'test_revive' ) : #NEWLINE# #INDENT# c = compat . Consumer ( self . connection , queue = c2 , exchange = n ) #NEWLINE# cs = compat . ConsumerSet ( self . connection , consumers = [ c ] ) #NEWLINE# with self . connection . channel ( ) as c2 : #NEWLINE# #INDENT# cs . revive ( c2 ) #NEWLINE# self . assertIs ( cs . backend , c2 )