Related to MassTransit#4356 - catch/retry exceptions when producing m…

…essages on connection failure for ActiveMQ transport
RJSonnenberg · Jun 6, 2023 · 312b8cd · 312b8cd
1 parent b74ec4e
commit 312b8cd
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/...assTransit.ActiveMqTransport/ActiveMqTransport/Configuration/ActiveMqHostConfiguration.cs b/...assTransit.ActiveMqTransport/ActiveMqTransport/Configuration/ActiveMqHostConfiguration.cs
@@ -1,6 +1,8 @@
 namespace MassTransit.ActiveMqTransport.Configuration
 {
     using System;
+    using System.Threading.Channels;
+    using Apache.NMS.ActiveMQ;
     using MassTransit.Configuration;
     using Topology;
     using Transports;
@@ -27,6 +29,8 @@ public ActiveMqHostConfiguration(IActiveMqBusConfiguration busConfiguration, IAc
             ReceiveTransportRetryPolicy = Retry.CreatePolicy(x =>
             {
                 x.Handle<ConnectionException>();
+                x.Handle<IOException>();
+                x.Handle<ChannelClosedException>();
 
                 x.Exponential(1000, TimeSpan.FromSeconds(3), TimeSpan.FromSeconds(30), TimeSpan.FromSeconds(3));
             });