+        # publish a message

+        self.channel.basic_publish(

+            exchange='',

+            routing_key=self.queue_name,

+            body="dummymessage"

+        )

+

+        res = self.create_queue(self.queue_name, True)

+        self.assertEqual(res.method.message_count, 1)

+

+        message_callback = MagicMock(side_effect=Exception("Failed to process message"))

+

+        consumer = BasicConsumer(self.rabbitmq_url,

+                                 self.queue_name,

+                                 self.queue_arguments,

+                                 message_callback

+                                 )

+        # start consumer

+        consumer.start()

+

+        # wait for the consumer to be ready

+        self.wait_for_log_contains(BasicConsumer.CONSUMER_READY)

+

+        # wait for the consumer to signal that is has consumed a message

+        self.wait_for_log_contains(BasicConsumer.CONSUMER_PROCESSED_MESSAGE)

+

+        # stop the consumer

+        consumer.join()

+

+        # assert that the message is still in the queue

+        res = self.channel.queue_declare(queue=self.queue_name, passive=True)

+        self.assertEqual(res.method.message_count, 1)

+

+        # since the message is rescheduled it might be processed many times before we stop the consumer