Skip to content
Browse files

Tests passing

  • Loading branch information...
1 parent 9cd9ed7 commit 1186cf82b4b3c60aa3bb48c8c880792b650dd665 @ask ask committed
Showing with 4 additions and 5 deletions.
  1. +3 −3 kombu/messaging.py
  2. +1 −2 kombu/serialization.py
View
6 kombu/messaging.py
@@ -475,7 +475,7 @@ def receive(self, body, message):
"""
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 @@ def _receive_callback(self, message):
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, )
View
3 kombu/serialization.py
@@ -1,4 +1,5 @@
"""
+ns
kombu.serialization
===================
@@ -381,5 +382,3 @@ def not_available(*args, **kwargs):
# Load entrypoints from installed extensions
for ep, args in entrypoints('kombu.serializers'):
register(ep.name, *args)
-
-

0 comments on commit 1186cf8

Please sign in to comment.
Something went wrong with that request. Please try again.