Fixed serialization problem in PublishModel/PublishHeaders examples (#…

…296) * Fixed a serialization problem in the sandbox/Example.Core.PublishModel/Header examples. - Added the reflection based JsonSerializer as default serializer. This way the Bar object can be (de)serialized and the examples work. * - Switched to using NatsJsonSerializerRegistry.Default instead of the default constructor. --------- Co-authored-by: Tobias Hoefer <tobias.hoefer@krones.com>
nats-io · Dec 21, 2023 · 31dc087 · 31dc087
1 parent 944caab
commit 31dc087
Show file tree

Hide file tree

Showing 8 changed files with 31 additions and 9 deletions.
diff --git a/sandbox/Example.Core.PublishHeaders/Example.Core.PublishHeaders.csproj b/sandbox/Example.Core.PublishHeaders/Example.Core.PublishHeaders.csproj
@@ -10,6 +10,7 @@
 
     <ItemGroup>
       <ProjectReference Include="..\..\src\NATS.Client.Core\NATS.Client.Core.csproj" />
+      <ProjectReference Include="..\..\src\NATS.Client.Serializers.Json\NATS.Client.Serializers.Json.csproj" />
     </ItemGroup>
 
     <ItemGroup>

diff --git a/sandbox/Example.Core.PublishHeaders/Program.cs b/sandbox/Example.Core.PublishHeaders/Program.cs
@@ -1,9 +1,14 @@
 // > nats sub bar.*
 using Microsoft.Extensions.Logging;
 using NATS.Client.Core;
+using NATS.Client.Serializers.Json;
 
 var subject = "bar.xyz";
-var options = NatsOpts.Default with { LoggerFactory = LoggerFactory.Create(builder => builder.AddConsole()) };
+var options = NatsOpts.Default with
+{
+    LoggerFactory = LoggerFactory.Create(builder => builder.AddConsole()),
+    SerializerRegistry = NatsJsonSerializerRegistry.Default,
+};
 
 Print("[CON] Connecting...\n");
 
@@ -12,7 +17,7 @@
 for (var i = 0; i < 10; i++)
 {
     Print($"[PUB] Publishing to subject ({i}) '{subject}'...\n");
-    await connection.PublishAsync<Bar>(
+    await connection.PublishAsync(
         subject,
         new Bar { Id = i, Name = "Baz" },
         headers: new NatsHeaders { ["XFoo"] = $"bar{i}" });

diff --git a/sandbox/Example.Core.PublishModel/Example.Core.PublishModel.csproj b/sandbox/Example.Core.PublishModel/Example.Core.PublishModel.csproj
@@ -10,6 +10,7 @@
 
     <ItemGroup>
       <ProjectReference Include="..\..\src\NATS.Client.Core\NATS.Client.Core.csproj" />
+      <ProjectReference Include="..\..\src\NATS.Client.Serializers.Json\NATS.Client.Serializers.Json.csproj" />
     </ItemGroup>
 
   <ItemGroup>

diff --git a/sandbox/Example.Core.PublishModel/Program.cs b/sandbox/Example.Core.PublishModel/Program.cs
@@ -1,9 +1,13 @@
 // > nats sub bar.*
 using Microsoft.Extensions.Logging;
 using NATS.Client.Core;
+using NATS.Client.Serializers.Json;
 
 var subject = "bar.xyz";
-var options = NatsOpts.Default with { LoggerFactory = LoggerFactory.Create(builder => builder.AddConsole()) };
+var options = NatsOpts.Default with {
+    LoggerFactory = LoggerFactory.Create(builder => builder.AddConsole()),
+    SerializerRegistry = NatsJsonSerializerRegistry.Default,
+};
 
 Print("[CON] Connecting...\n");
 
@@ -12,7 +16,7 @@
 for (var i = 0; i < 10; i++)
 {
     Print($"[PUB] Publishing to subject ({i}) '{subject}'...\n");
-    await connection.PublishAsync<Bar>(subject, new Bar { Id = i, Name = "Baz" });
+    await connection.PublishAsync(subject, new Bar { Id = i, Name = "Baz" });
 }
 
 void Print(string message)

diff --git a/sandbox/Example.Core.SubscribeHeaders/Example.Core.SubscribeHeaders.csproj b/sandbox/Example.Core.SubscribeHeaders/Example.Core.SubscribeHeaders.csproj
@@ -10,6 +10,7 @@
 
     <ItemGroup>
       <ProjectReference Include="..\..\src\NATS.Client.Core\NATS.Client.Core.csproj" />
+      <ProjectReference Include="..\..\src\NATS.Client.Serializers.Json\NATS.Client.Serializers.Json.csproj" />
     </ItemGroup>
 
   <ItemGroup>

diff --git a/sandbox/Example.Core.SubscribeHeaders/Program.cs b/sandbox/Example.Core.SubscribeHeaders/Program.cs
@@ -1,21 +1,25 @@
 // > nats pub bar.xyz --count=10 "my_message_{{ Count }}" -H X-Foo:Baz
 
-using System.Text;
 using Microsoft.Extensions.Logging;
 using NATS.Client.Core;
+using NATS.Client.Serializers.Json;
 
 var subject = "bar.*";
-var options = NatsOpts.Default with { LoggerFactory = LoggerFactory.Create(builder => builder.AddConsole()) };
+var options = NatsOpts.Default with
+{
+    LoggerFactory = LoggerFactory.Create(builder => builder.AddConsole()),
+    SerializerRegistry = NatsJsonSerializerRegistry.Default,
+};
 
 Print("[CON] Connecting...\n");
 
 await using var connection = new NatsConnection(options);
 
 Print($"[SUB] Subscribing to subject '{subject}'...\n");
 
-await foreach (var msg in connection.SubscribeAsync<byte[]>(subject))
+await foreach (var msg in connection.SubscribeAsync<Bar>(subject))
 {
-    Print($"[RCV] {msg.Subject}: {Encoding.UTF8.GetString(msg.Data!)}\n");
+    Print($"[RCV] {msg.Subject}: {msg.Data!}\n");
     if (msg.Headers != null)
     {
         foreach (var (key, values) in msg.Headers)

diff --git a/sandbox/Example.Core.SubscribeModel/Example.Core.SubscribeModel.csproj b/sandbox/Example.Core.SubscribeModel/Example.Core.SubscribeModel.csproj
@@ -10,6 +10,7 @@
 
     <ItemGroup>
       <ProjectReference Include="..\..\src\NATS.Client.Core\NATS.Client.Core.csproj" />
+      <ProjectReference Include="..\..\src\NATS.Client.Serializers.Json\NATS.Client.Serializers.Json.csproj" />
     </ItemGroup>
 
   <ItemGroup>

diff --git a/sandbox/Example.Core.SubscribeModel/Program.cs b/sandbox/Example.Core.SubscribeModel/Program.cs
@@ -1,8 +1,13 @@
 using Microsoft.Extensions.Logging;
 using NATS.Client.Core;
+using NATS.Client.Serializers.Json;
 
 var subject = "bar.*";
-var options = NatsOpts.Default with { LoggerFactory = LoggerFactory.Create(builder => builder.AddConsole()) };
+var options = NatsOpts.Default with
+{
+    LoggerFactory = LoggerFactory.Create(builder => builder.AddConsole()),
+    SerializerRegistry = NatsJsonSerializerRegistry.Default,
+};
 
 Print("[CON] Connecting...\n");