Merge branch 'release/3.0.1'

MvRens · Mar 30, 2023 · 871e418 · 871e418
2 parents 36b68c2 + 3c7dc09
commit 871e418
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/Tapeti/Connection/TapetiClient.cs b/Tapeti/Connection/TapetiClient.cs
@@ -313,7 +313,7 @@ private async Task<bool> GetDurableQueueDeclareRequired(string queueName, IRabbi
         }
 
 
-        private static RabbitMQArguments? ConvertJsonArguments(IReadOnlyDictionary<string, JObject>? arguments)
+        private static RabbitMQArguments? ConvertJsonArguments(IReadOnlyDictionary<string, JValue>? arguments)
         {
             if (arguments == null)
                 return null;
@@ -326,7 +326,7 @@ private async Task<bool> GetDurableQueueDeclareRequired(string queueName, IRabbi
                 {
                     JTokenType.Integer => pair.Value.Value<int>(),
                     JTokenType.Float => pair.Value.Value<double>(),
-                    JTokenType.String => Encoding.UTF8.GetBytes(pair.Value.Value<string>() ?? string.Empty),
+                    JTokenType.String => pair.Value.Value<string>() ?? string.Empty,
                     JTokenType.Boolean => pair.Value.Value<bool>(),
                     _ => throw new ArgumentOutOfRangeException(nameof(arguments))
                 };
@@ -599,7 +599,7 @@ private class ManagementQueueInfo
             public bool Exclusive { get; set; }
 
             [JsonProperty("arguments")]
-            public Dictionary<string, JObject>? Arguments { get; set; }
+            public Dictionary<string, JValue>? Arguments { get; set; }
 
             [JsonProperty("messages")]
             public uint Messages { get; set; }