diff --git a/pulsar/client/manager.py b/pulsar/client/manager.py index 120a65315fb5a0a6c2feb3044a1c02b51dfc6798..ce25c264dd562d549234129aa94edaccc2e105ef 100644 --- a/pulsar/client/manager.py +++ b/pulsar/client/manager.py @@ -96,7 +96,13 @@ class MessageQueueClientManager(object): def callback_wrapper(body, message): if not self.active: - message.requeue() + log.debug("Obtained update message for inactive client manager, attempting requeue.") + try: + message.requeue() + log.debug("Requeue succeeded, will likely be handled next time consumer is enabled.") + except Exception: + log.debug("Requeue failed, message may be lost?") + return try: if "job_id" in body: