Add hook when Consumer loses connection to RMQ #290
-
|
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. |
Beta Was this translation helpful? Give feedback.
Answered by
acogoluegnes
Feb 20, 2023
Replies: 1 comment
-
|
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. |
Beta Was this translation helpful? Give feedback.
0 replies
Answer selected by
acogoluegnes
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
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.