nats-io / nats.go / 15780367894

85%

push

github

[FIXED] Consumer.Next() hangs after connection is closed (#1883)

* [FIXED] JetStream consumer hanging after connection closure

Fixes #1875

JetStream consumer operations would hang indefinitely after server
shutdown or connection closure.

Changes:
- Fixed core NATS closed handler bug for ChanSubscription and SyncSubscription
- Added ErrConnectionClosed error for better error context
- Enhanced Consume() to report connection closure via ConsumeErrHandler
- Improved Next() to wrap ErrMsgIteratorClosed with ErrConnectionClosed

Both Messages().Next() and consumer.Consume() now properly handle connection
closure and provide appropriate error reporting to applications.

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>

* Fix consume not sending conn closed error, improve tests

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>

---------

Signed-off-by: Piotr Piotrowski <piotr@synadia.com>

31 of 33 new or added lines in 3 files covered. (93.94%)

13726 of 16194 relevant lines covered (84.76%)

31424.13 hits per line