on_decode_error: Use repr() not str(). Closes #297. Thanks to gthb

celery/tests/test_worker.py

@@ -336,7 +336,7 @@ class test_Consumer(unittest.TestCase):
         message = MockMessage()
         l.on_decode_error(message, KeyError("foo"))
         self.assertTrue(message.acked)
-        self.assertIn("Message decoding error", logger.logged[0])
+        self.assertIn("Can't decode message body", logger.logged[0])
 
     def test_receieve_message(self):
         l = MyKombuConsumer(self.ready_queue, self.eta_schedule, self.logger,

celery/worker/consumer.py

@@ -401,8 +401,8 @@ class Consumer(object):
         :param exc: The original exception instance.
 
         """
-        self.logger.critical("Message decoding error: %s "
-                             "(type:%s encoding:%s raw:'%s')" % (
+        self.logger.critical("Can't decode message body: %r "
+                             "(type:%r encoding:%r raw:%r')" % (
                                 exc, message.content_type,
                                 message.content_encoding, message.body))
         message.ack()