v 2.4.3.1

jlnovais · Nov 2, 2022 · 3a7cf0b · 3a7cf0b
1 parent ba74cae
commit 3a7cf0b
Show file tree

Hide file tree

Showing 4 changed files with 16 additions and 6 deletions.
diff --git a/JN.RabbitMQClient.TestApp/HelperClasses/SettingsHelper.cs b/JN.RabbitMQClient.TestApp/HelperClasses/SettingsHelper.cs
@@ -31,7 +31,8 @@ public static BrokerConfigConsumers GetBrokerConfigConsumers(this IConfiguration
                 RoutingKeyOrQueueName = section["RoutingKeyOrQueueName"],
                 TotalInstances = totalInstances,
                 ShuffleHostList = shuffleHostList,
-                UseTLS = useTls
+                UseTLS = useTls,
+                ConnectionTimeoutSeconds = Convert.ToInt16(section["ConnectionTimeoutSeconds"])
             };
 
             return conf;
@@ -56,7 +57,8 @@ public static BrokerConfigSender GetBrokerConfigSender(this IConfiguration confi
                 RoutingKeyOrQueueName = section["RoutingKeyOrQueueName"],
                 ShuffleHostList = shuffleHostList,
                 UseTLS = useTls,
-                KeepConnectionOpen = keepConnectionOpen
+                KeepConnectionOpen = keepConnectionOpen,
+                ConnectionTimeoutSeconds = Convert.ToInt16(section["ConnectionTimeoutSeconds"])
 
             };
 

diff --git a/JN.RabbitMQClient.TestApp/Program.cs b/JN.RabbitMQClient.TestApp/Program.cs
@@ -95,6 +95,8 @@ private static IServiceCollection ConfigureServices()
                 options.ShuffleHostList = userOptions.ShuffleHostList;
                 options.UseTLS = userOptions.UseTLS;
                 options.VirtualHost = userOptions.VirtualHost;
+                options.ConnectionTimeoutSeconds = userOptions.ConnectionTimeoutSeconds;
+
             });
 
             services.AddSenderService(configSender);

diff --git a/JN.RabbitMQClient.TestApp/appsettings.json b/JN.RabbitMQClient.TestApp/appsettings.json
@@ -12,7 +12,8 @@
     "ShuffleHostList": true,
     "TotalInstances": 1,
     "UseTLS": false,
-    "ConsumersPrefetch": 3
+    "ConsumersPrefetch": 3,
+    "ConnectionTimeoutSeconds": 3
   },
 
   "BrokerConfigSender": {
@@ -25,7 +26,8 @@
     "Exchange": "",
     "UseTLS": false,
     "KeepConnectionOpen": true,
-    "ShuffleHostList": false
+    "ShuffleHostList": false,
+    "ConnectionTimeoutSeconds": 4
   },
 
   "BrokerConfigConsumersRetry": {

diff --git a/JN.RabbitMQClient/JN.RabbitMQClient.nuspec b/JN.RabbitMQClient/JN.RabbitMQClient.nuspec
@@ -2,7 +2,7 @@
 <package xmlns="http://schemas.microsoft.com/packaging/2013/05/nuspec.xsd">
   <metadata>
     <id>JN.RabbitMQClient</id>
-    <version>2.4.3</version>
+    <version>2.4.3.1</version>
     <authors>José Novais</authors>
     <owners>José Novais</owners>
     <requireLicenseAcceptance>false</requireLicenseAcceptance>
@@ -17,7 +17,11 @@
     <summary>Simple implementation of RabbitMQ consumer and sender.</summary>
     <copyright>José Novais, 2022</copyright>
     <releaseNotes>
-		Release Notes for current version (2.4.3):
+	    Release Notes for current version 2.4.3.1:
+
+	    - Added connection timeout
+
+		Release Notes for version 2.4.3:
 
 		- Added service extensions AddConsumersService() and AddSenderService() (in namespace JN.RabbitMQClient.Extensions)
 		- Added ConnectionDetails readonly property