diff --git a/kombu/messaging.py b/kombu/messaging.py
index 03ac2dd8..ead5ae9e 100644
--- a/kombu/messaging.py
+++ b/kombu/messaging.py
@@ -475,7 +475,7 @@ class Consumer(object):
         """
         callbacks = self.callbacks
         if not callbacks:
-            raise NotImplementedError('Consumer does not have any callback')
+            raise NotImplementedError('Consumer does not have any callbacks')
         [callback(body, message) for callback in callbacks]
 
     def _basic_consume(self, queue, consumer_tag=None,
@@ -503,8 +503,8 @@ class Consumer(object):
             if not self.on_decode_error:
                 raise
             self.on_decode_error(message, exc)
-
-        return on_m(message) if on_m else self.receive(decoded, message)
+        else:
+            return on_m(message) if on_m else self.receive(decoded, message)
 
     def __repr__(self):
         return '<Consumer: %s>' % (self.queues, )
diff --git a/kombu/serialization.py b/kombu/serialization.py
index 237316b5..3be9ae1c 100644
--- a/kombu/serialization.py
+++ b/kombu/serialization.py
@@ -1,4 +1,5 @@
 """
+ns
 kombu.serialization
 ===================
 
@@ -381,5 +382,3 @@ registry._set_default_serializer('json')
 # Load entrypoints from installed extensions
 for ep, args in entrypoints('kombu.serializers'):
     register(ep.name, *args)
-
-