diff --git a/Tapeti/Connection/TapetiClient.cs b/Tapeti/Connection/TapetiClient.cs index ec1316b..07e2718 100644 --- a/Tapeti/Connection/TapetiClient.cs +++ b/Tapeti/Connection/TapetiClient.cs @@ -313,7 +313,7 @@ namespace Tapeti.Connection } - private static RabbitMQArguments? ConvertJsonArguments(IReadOnlyDictionary? arguments) + private static RabbitMQArguments? ConvertJsonArguments(IReadOnlyDictionary? arguments) { if (arguments == null) return null; @@ -326,7 +326,7 @@ namespace Tapeti.Connection { JTokenType.Integer => pair.Value.Value(), JTokenType.Float => pair.Value.Value(), - JTokenType.String => Encoding.UTF8.GetBytes(pair.Value.Value() ?? string.Empty), + JTokenType.String => pair.Value.Value() ?? string.Empty, JTokenType.Boolean => pair.Value.Value(), _ => throw new ArgumentOutOfRangeException(nameof(arguments)) }; @@ -599,7 +599,7 @@ namespace Tapeti.Connection public bool Exclusive { get; set; } [JsonProperty("arguments")] - public Dictionary? Arguments { get; set; } + public Dictionary? Arguments { get; set; } [JsonProperty("messages")] public uint Messages { get; set; }