Implementing Resilient RabbitMQ Connections in a Layered Architecture
Hello, I am trying to provide a RabbitMQ connection to my program inside a
So far my code works great, but is not resilient to connection failures. When the connection is broken with Rabbit server, the connection object does not work anymore but is still provided to my program, which creates a bunch of errors with I want to publish messages or subscribe. I would like to have a way to always provide a working connection to my program.
One way is to detect when the connection fails and automatically refresh the connection, but how could I "refresh" a context / layer ?
Currently I am able to watch the connection errors inside a
I was also thinking to provide a
What would be the best way to do this ?
Layer.scopedSo far my code works great, but is not resilient to connection failures. When the connection is broken with Rabbit server, the connection object does not work anymore but is still provided to my program, which creates a bunch of errors with I want to publish messages or subscribe. I would like to have a way to always provide a working connection to my program.
One way is to detect when the connection fails and automatically refresh the connection, but how could I "refresh" a context / layer ?
Currently I am able to watch the connection errors inside a
StreamI was also thinking to provide a
SynchronizedRefWhat would be the best way to do this ?
Similar Threads
Was this page helpful?
