Merge pull request danielgerlag#1286 from JoaquimInGit/feat-update-rabbitmq

danielgerlag · web-flow · commit b40d184ba1e3 · 2024-08-14T13:20:02.000-07:00
Feat update rabbitmq
diff --git a/src/providers/WorkflowCore.QueueProviders.RabbitMQ/Services/RabbitMQProvider.cs b/src/providers/WorkflowCore.QueueProviders.RabbitMQ/Services/RabbitMQProvider.cs
@@ -63,7 +63,7 @@ public async Task<string> DequeueWork(QueueType queue, CancellationToken cancell
                 var msg = channel.BasicGet(_queueNameProvider.GetQueueName(queue), false);
                 if (msg != null)
                 {
-                    var data = Encoding.UTF8.GetString(msg.Body);
+                    var data = Encoding.UTF8.GetString(msg.Body.ToArray());
                     channel.BasicAck(msg.DeliveryTag, false);
                     return data;
                 }
diff --git a/src/providers/WorkflowCore.QueueProviders.RabbitMQ/WorkflowCore.QueueProviders.RabbitMQ.csproj b/src/providers/WorkflowCore.QueueProviders.RabbitMQ/WorkflowCore.QueueProviders.RabbitMQ.csproj
@@ -23,7 +23,7 @@
 
   <ItemGroup>
     <PackageReference Include="Newtonsoft.Json" Version="13.0.1" />
-    <PackageReference Include="RabbitMQ.Client" Version="4.1.3" />
+    <PackageReference Include="RabbitMQ.Client" Version="6.8.1" />
   </ItemGroup>
 
 </Project>

Original file line number	Diff line number	Diff line change
`@@ -63,7 +63,7 @@ public async Task<string> DequeueWork(QueueType queue, CancellationToken cancell`
`63`	`63`	`var msg = channel.BasicGet(_queueNameProvider.GetQueueName(queue), false);`
`64`	`64`	`if (msg != null)`
`65`	`65`	`{`
`66`		`- var data = Encoding.UTF8.GetString(msg.Body);`
	`66`	`+ var data = Encoding.UTF8.GetString(msg.Body.ToArray());`
`67`	`67`	`channel.BasicAck(msg.DeliveryTag, false);`
`68`	`68`	`return data;`
`69`	`69`	`}`