Add hook when Consumer loses connection to RMQ

[peter-a]

If RMQ goes down for some reason, I need to provide some fallback logic. Currently there is no hook for this scenario. I tried implementing https://github.com/rabbitmq/rabbitmq-stream-java-client/blob/main/src/main/java/com/rabbitmq/stream/ConsumerUpdateListener.java but this listener is not called when RMQ is down.

[acogoluegnes]

Can you please tell us more about the fallback logic you're mentioning?

The client library takes care of reconnecting and re-enabling producer and consumer instances.