Merge pull request #523 from sjlongland/callback_exception

pika: callback: Display exception message when callback fails.
pika · Apr 29, 2015 · 5640d03 · 5640d03
2 parents d235989 + 562aa15
commit 5640d03
Showing 1 changed file with 6 additions and 1 deletion.
diff --git a/pika/callback.py b/pika/callback.py
@@ -234,7 +234,12 @@ def process(self, prefix, key, caller, *args, **keywords):
         # Call each callback
         for callback in callbacks:
             LOGGER.debug('Calling %s for "%s:%s"', callback, prefix, key)
-            callback(*args, **keywords)
+            try:
+                callback(*args, **keywords)
+            except:
+                LOGGER.exception('Calling %s for "%s:%s" failed',
+                        callback, prefix, key)
+                raise
         return True
 
     @sanitize_prefix