From a49684529bf65fa15ac9715d298cb1bd6abd45d1 Mon Sep 17 00:00:00 2001
From: Joaquim Tomas <joaquimemtomas@gmail.com>
Date: Wed, 14 Aug 2024 10:43:51 +0100
Subject: [PATCH 1/2] bump: rabbitmq client version to 6.8.1

---
 .../WorkflowCore.QueueProviders.RabbitMQ.csproj                 | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/providers/WorkflowCore.QueueProviders.RabbitMQ/WorkflowCore.QueueProviders.RabbitMQ.csproj b/src/providers/WorkflowCore.QueueProviders.RabbitMQ/WorkflowCore.QueueProviders.RabbitMQ.csproj
index 3ef1064ae..df02daa76 100644
--- 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>

From fd19caa4ac81bda6ee05fb5c28dbc5599eaad885 Mon Sep 17 00:00:00 2001
From: Joaquim Tomas <joaquimemtomas@gmail.com>
Date: Wed, 14 Aug 2024 10:44:25 +0100
Subject: [PATCH 2/2] fix: readonlymemory byte to byte array

---
 .../Services/RabbitMQProvider.cs                                | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/providers/WorkflowCore.QueueProviders.RabbitMQ/Services/RabbitMQProvider.cs b/src/providers/WorkflowCore.QueueProviders.RabbitMQ/Services/RabbitMQProvider.cs
index 64322ad50..8a4ab33bb 100644
--- 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;
                 }