We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 57ce40b commit 3ec8799Copy full SHA for 3ec8799
src/main/scala/com/thenewmotion/akka/rabbitmq/ConnectionActor.scala
@@ -128,7 +128,14 @@ class ConnectionActor(
128
children.foreach(_ ! ParentShutdownSignal)
129
}
130
131
+ /**
132
+ * As connection recovery at this level does not play well
133
+ * with [[http://www.rabbitmq.com/api-guide.html#recovery native recovery]]
134
+ * factory settings are changed to disable it even if it was enabled
135
+ * to ensure correctness of operations.
136
+ */
137
def setup = {
138
+ factory.setAutomaticRecoveryEnabled(false)
139
val connection = factory.newConnection()
140
log.debug("setting up new connection {}", connection)
141
connection.addShutdownListener(this)
0 commit comments