The current implementation was re-using the cached, invalid connection repeatedly and not actually creating a new one. The new implementation takes multi-consumer into account, properly creates new connections, and cleans up some bad logic around retry implementation.
The current implementation was re-using the cached, invalid connection repeatedly and not actually creating a new one. The new implementation takes multi-consumer into account, properly creates new connections, and cleans up some bad logic around retry implementation.