#NEWLINE# def test_runs_consumer( self , fake_consumer , queue ) : #NEWLINE# #INDENT# messages . process_messages ( { #NEWLINE# #INDENT# #NEWLINE# #UNINDENT# } , 'foobar' , queue , raise_error = False ) #NEWLINE# consumer = fake_consumer . return_value #NEWLINE# consumer . run . assert_called_once_with ( )