added autorecovery to rabbit connection (#18)

Co-authored-by: IB <[email protected]>
vchain-dev · Nov 10, 2023 · a250c42 · a250c42
1 parent 0a0bdb2
commit a250c42
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/src/main/kotlin/RabbitMQBroker.kt b/src/main/kotlin/RabbitMQBroker.kt
@@ -38,6 +38,7 @@ class RabbitMQBroker(
             factory.metricsCollector = metricsCollector
         }
         factory.setUri(uri)
+        factory.isAutomaticRecoveryEnabled = true
         connection = factory.newConnection()
         channel = connection.createChannel()