configure RabbitMq continuation timeout (#2879)

Co-authored-by: Benjamin SCHMITT <[email protected]> Co-authored-by: Ian Cooper <[email protected]>
BrighterCommand · Oct 22, 2023 · a574fec · a574fec
1 parent 0a12b20
commit a574fec
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/src/Paramore.Brighter.MessagingGateway.RMQ/RmqMessageGateway.cs b/src/Paramore.Brighter.MessagingGateway.RMQ/RmqMessageGateway.cs
@@ -76,7 +76,8 @@ protected RmqMessageGateway(RmqMessagingGatewayConnection connection)
             _connectionFactory = new ConnectionFactory
             {
                 Uri = Connection.AmpqUri.Uri,
-                RequestedHeartbeat = TimeSpan.FromSeconds(connection.Heartbeat)
+                RequestedHeartbeat = TimeSpan.FromSeconds(connection.Heartbeat),
+                ContinuationTimeout = TimeSpan.FromSeconds(connection.ContinuationTimeout)
             };
 
             DelaySupported = Connection.Exchange.SupportDelay;

diff --git a/src/Paramore.Brighter.MessagingGateway.RMQ/RmqMessagingGatewayConnection.cs b/src/Paramore.Brighter.MessagingGateway.RMQ/RmqMessagingGatewayConnection.cs
@@ -67,6 +67,11 @@ public RmqMessagingGatewayConnection()
         /// </summary>
         public bool PersistMessages { get; set; }
 
+        /// <summary>
+        ///     Gets or sets RabbitMq protocol timeouts, in seconds. Defaults to 20s.
+        ///     <see cref="ConnectionFactory.ContinuationTimeout" /> for more information.
+        /// </summary>
+        public ushort ContinuationTimeout { get; set; } = 20;
     }
 
     /// <summary>