diff options
Diffstat (limited to 'kombu/async/hub.py')
| -rw-r--r-- | kombu/async/hub.py | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/kombu/async/hub.py b/kombu/async/hub.py index 673a60ac..264f8188 100644 --- a/kombu/async/hub.py +++ b/kombu/async/hub.py @@ -247,6 +247,11 @@ class Hub(object): self.writers.pop(fd, None) self.consolidate.discard(fd) + def on_callback_error(self, callback, exc): + logger.error( + 'Callback %r raised exception: %r', callback, exc, exc_info=1, + ) + def create_loop(self, generator=generator, sleep=sleep, min=min, next=next, Empty=Empty, StopIteration=StopIteration, |