diff --git a/fedora_messaging/_session.py b/fedora_messaging/_session.py index 7eb78eab..b20802f8 100644 --- a/fedora_messaging/_session.py +++ b/fedora_messaging/_session.py @@ -495,7 +495,7 @@ def consume(self, callback, bindings=None, queues=None, exchanges=None): " or a function." ) self._consumer_callback = cb_obj - elif inspect.isfunction(callback): + elif inspect.isfunction(callback) or inspect.ismethod(callback): self._consumer_callback = callback else: raise ValueError(