Akka amqp heartbeat option and fault tolerance

Question

So, I don't see a way to easily set up a factory connection for AMQP. It is embedded deep enough in a batch private class that without explicit structural casting like this does not seem to have a solution. I need to enable the heartbeat function on it using the setter.

Now, even if there is a way to install it (I don’t see how), the actor’s AMQP does not seem to be able to reconnect if an exception is thrown, which is thrown when the heartbeat fails. Let me know if these observations are observed. I would really like to continue to use the amkp akka module, but I will have to rewrite it using raw amqp-client, if this is not possible above. Many thanks. Ilya