Skip to content

Commit 2aab995

Browse files
committed
[Host.Serialization.SystemTextJson] Pass the actual message type by default during serialization
Signed-off-by: Tomasz Maruszak <maruszaktomasz@gmail.com>
1 parent 0f57f29 commit 2aab995

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

src/Host.Plugin.Properties.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@
44
<Import Project="Common.NuGet.Properties.xml" />
55

66
<PropertyGroup>
7-
<Version>3.3.7-rc200</Version>
7+
<Version>3.4.0-rc100</Version>
88
</PropertyGroup>
99

1010
</Project>

src/SlimMessageBus.Host.Serialization.SystemTextJson/JsonMessageSerializer.cs

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@
99
/// </summary>
1010
public class JsonMessageSerializer : IMessageSerializer, IMessageSerializer<string>, IMessageSerializerProvider
1111
{
12-
private readonly bool _passActualTypeOnSerialize;
12+
private readonly bool _useActualTypeOnSerialize;
1313

1414
/// <summary>
1515
/// <see cref="JsonSerializerOptions"/> options for the JSON serializer. By default adds <see cref="ObjectToInferredTypesConverter"/> converter.
@@ -19,7 +19,7 @@ public class JsonMessageSerializer : IMessageSerializer, IMessageSerializer<stri
1919
public JsonMessageSerializer(JsonSerializerOptions options = null, bool useActualTypeOnSerialize = true)
2020
{
2121
Options = options ?? CreateDefaultOptions();
22-
_passActualTypeOnSerialize = useActualTypeOnSerialize;
22+
_useActualTypeOnSerialize = useActualTypeOnSerialize;
2323
}
2424

2525
public virtual JsonSerializerOptions CreateDefaultOptions()
@@ -37,7 +37,7 @@ public virtual JsonSerializerOptions CreateDefaultOptions()
3737
#region Implementation of IMessageSerializer
3838

3939
public byte[] Serialize(Type messageType, IDictionary<string, object> headers, object message, object transportMessage)
40-
=> JsonSerializer.SerializeToUtf8Bytes(message, _passActualTypeOnSerialize && message != null ? message.GetType() : messageType, Options);
40+
=> JsonSerializer.SerializeToUtf8Bytes(message, _useActualTypeOnSerialize && message != null ? message.GetType() : messageType, Options);
4141

4242
public object Deserialize(Type messageType, IReadOnlyDictionary<string, object> headers, byte[] payload, object transportMessage)
4343
=> JsonSerializer.Deserialize(payload, messageType, Options)!;
@@ -47,7 +47,7 @@ public object Deserialize(Type messageType, IReadOnlyDictionary<string, object>
4747
#region Implementation of IMessageSerializer<string>
4848

4949
string IMessageSerializer<string>.Serialize(Type messageType, IDictionary<string, object> headers, object message, object transportMessage)
50-
=> JsonSerializer.Serialize(message, _passActualTypeOnSerialize && message != null ? message.GetType() : messageType, Options);
50+
=> JsonSerializer.Serialize(message, _useActualTypeOnSerialize && message != null ? message.GetType() : messageType, Options);
5151

5252
public object Deserialize(Type messageType, IReadOnlyDictionary<string, object> headers, string payload, object transportMessage)
5353
=> JsonSerializer.Deserialize(payload, messageType, Options)!;

0 commit comments

Comments
 (0)