[CURATOR-336] QueueConsumer does not get any connection state updates

[jira-importer]

According to http://curator.apache.org/curator-recipes/distributed-queue.html#Error_Handling, the QueueConsumer implementer can receive connection state updates. However, in fact, my consumer is never notified of any state updates when the connection is down. By checking the source code of DistributedQueue, I found that indeed no class is invoking the "stateChanged" callback of QueueConsumer.

Am I missing something?

---

Originally reported by liulong0118, imported from: QueueConsumer does not get any connection state updates

• status: Open
• priority: Critical
• resolution: Unresolved
• imported: 2025-01-21