#NEWLINE# def test_process_next( self , n = 'test_process_next' ) : #NEWLINE# #INDENT# c = compat . Consumer ( self . connection , queue = n , exchange = n , routing_key = 'rkey' ) #NEWLINE# with self . assertRaises ( NotImplementedError ) : #NEWLINE# #INDENT# c . process_next ( ) #NEWLINE# #UNINDENT# c . close ( )