version 2.3.4

jlnovais · Dec 28, 2021 · a00b438 · a00b438
1 parent 183d527
commit a00b438
Show file tree

Hide file tree

Showing 5 changed files with 15 additions and 13 deletions.
diff --git a/JN.RabbitMQClient/JN.RabbitMQClient.csproj b/JN.RabbitMQClient/JN.RabbitMQClient.csproj
@@ -8,9 +8,9 @@
     <PackageProjectUrl>https://github.com/jlnovais/JN.RabbitMQClient</PackageProjectUrl>
     <Copyright>José Novais, 2021</Copyright>
     <Product>JN.RabbitMQClient - Simple RabbitMQ client</Product>
-    <AssemblyVersion>2.3.3</AssemblyVersion>
-    <FileVersion>2.3.3</FileVersion>
-    <Version>2.3.3</Version>
+    <AssemblyVersion>2.3.4</AssemblyVersion>
+    <FileVersion>2.3.4</FileVersion>
+    <Version>2.3.4</Version>
     <PackageIcon>packageIcon.png</PackageIcon>
   </PropertyGroup>
 

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.3.3</version>
+    <version>2.3.4</version>
     <authors>José Novais</authors>
     <owners>José Novais</owners>
     <requireLicenseAcceptance>false</requireLicenseAcceptance>
@@ -16,18 +16,22 @@
     <description>Simple implementation of RabbitMQ consumer and sender.</description>
     <summary>Simple implementation of RabbitMQ consumer and sender.</summary>
     <copyright>José Novais, 2021</copyright>
-    <releaseNotes> 
-      Release Notes for current version:
+    <releaseNotes>
+      Release Notes for current version (2.3.4):
+
+      - Added support for additional information to be passed to the processing delegate; the processing instruction is now an object 'MessageProcessInstruction' where that additional information can be passed. Useful for when a message is requeued with delay to pass information to the next processing attempt.
+
+      Release Notes for version 2.3.3:
 
       - Update target frameworks; added .NETFramework4.6.1
       - Update RabbitMQ.Client to latest version
       - Update consumer to expose MaxChannelsPerConnection property
 
-      Release Notes for previous version:
+      Release Notes for version 2.3.2:
 
       - Added sender service that keeps connection open.
 
-      Release Notes for other previous version:
+      Release Notes for version 2.3.0:
 
       - Update RabbitMQ.Client to latest version
       - Changed namespace for IRabbitMqConsumerService and IRabbitMqSenderService

diff --git a/JN.RabbitMQClient/Other/RabbitMqUtilities.cs b/JN.RabbitMQClient/Other/RabbitMqUtilities.cs
@@ -29,8 +29,6 @@ internal static long GetFirstErrorTimeStampFromMessageArgs(IBasicProperties prop
 
         internal static string GetAdditionalInfoFromMessageArgs(IBasicProperties properties)
         {
-            string res = null;
-
             if (properties?.Headers == null)
                 return null;
 
@@ -41,7 +39,7 @@ internal static string GetAdditionalInfoFromMessageArgs(IBasicProperties propert
                 return null;
 
             var value = (byte[]) properties.Headers[Constants.MessageAdditionalInfoHeaderName];
-            res = Encoding.UTF8.GetString(value);
+            var res = Encoding.UTF8.GetString(value);
 
             return res;
         }

diff --git a/JN.RabbitMQClient/RabbitMqConsumerService.cs b/JN.RabbitMQClient/RabbitMqConsumerService.cs
@@ -318,7 +318,7 @@ private async Task<MessageProcessInstruction> GetMessageProcessInstruction(strin
                 isAllowed = Limiter.IsAllowed(routingKeyOrQueueName, consumerTag, firstErrorTimestamp, exchange, message);
 
             if (!isAllowed)
-                return new MessageProcessInstruction {Value = Limiter.DeniedProcessInstruction};
+                return new MessageProcessInstruction(Limiter.DeniedProcessInstruction, messageAdditionalInfo);
 
             var messageProcessInstruction =
                 await OnReceiveMessage(routingKeyOrQueueName, consumerTag, firstErrorTimestamp, exchange, message, messageAdditionalInfo)

diff --git a/README.md b/README.md
@@ -11,7 +11,7 @@ Simple implementation of RabbitMQ consumer and sender.
 *   Multiple processing options for received messages
 *   Random expiration for messages sent to an holding queue (depending on the processing option)
 *   TLS connection support 
-*   [Limiter for message processing](https://josenovais.azurewebsites.net/JN-RabbitMQClient/#limiter)
+*   [Limiter for message processing](https://jn-rabbitmqclient.josenovais.com/#limiter)
 
 More details available on the [project website](https://jn-rabbitmqclient.josenovais.com/).