Use serializer from configuration object

BookBeat · May 13, 2024 · 4369e03 · 4369e03
1 parent acc163d
commit 4369e03
Show file tree

Hide file tree

Showing 5 changed files with 9 additions and 6 deletions.
diff --git a/...bus-postgresql/src/KnightBus.PostgreSql.Management/KnightBus.PostgreSql.Management.csproj b/...bus-postgresql/src/KnightBus.PostgreSql.Management/KnightBus.PostgreSql.Management.csproj
@@ -11,7 +11,7 @@
     <PackageIconUrl>https://raw.githubusercontent.com/BookBeat/knightbus/master/documentation/media/images/knighbus-64.png</PackageIconUrl>
     <PackageIcon>knighbus-64.png</PackageIcon>
     <RepositoryUrl>https://github.com/BookBeat/knightbus</RepositoryUrl>
-    <Version>1.1.1</Version>
+    <Version>1.1.2</Version>
     <PackageTags>knightbus;postgresql;queues;messaging</PackageTags>
     <LangVersion>latest</LangVersion>
     <ImplicitUsings>enable</ImplicitUsings>

diff --git a/knightbus-postgresql/src/KnightBus.PostgreSql.Management/PostgresManagementClient.cs b/knightbus-postgresql/src/KnightBus.PostgreSql.Management/PostgresManagementClient.cs
@@ -10,10 +10,10 @@ public class PostgresManagementClient
     private readonly NpgsqlDataSource _npgsqlDataSource;
     private readonly IMessageSerializer _serializer;
 
-    public PostgresManagementClient(NpgsqlDataSource npgsqlDataSource, IMessageSerializer serializer)
+    public PostgresManagementClient(NpgsqlDataSource npgsqlDataSource, IPostgresConfiguration configuration)
     {
         _npgsqlDataSource = npgsqlDataSource;
-        _serializer = serializer;
+        _serializer = configuration.MessageSerializer;
     }
 
     public async Task<List<PostgresQueueMetadata>> ListQueues(CancellationToken ct)

diff --git a/knightbus-postgresql/tests/KnightBus.PostgreSql.Tests.Integration/PostgresBusTests.cs b/knightbus-postgresql/tests/KnightBus.PostgreSql.Tests.Integration/PostgresBusTests.cs
@@ -19,7 +19,8 @@ public async Task OneTimeSetUp()
     {
         _postgresBus = new PostgresBus(PostgresTestBase.TestNpgsqlDataSource, new PostgresConfiguration());
         _postgresQueueClient = new PostgresQueueClient<TestCommand>(PostgresTestBase.TestNpgsqlDataSource, new MicrosoftJsonSerializer());
-        _postgresManagementClient = new PostgresManagementClient(PostgresTestBase.TestNpgsqlDataSource, new MicrosoftJsonSerializer());
+        _postgresManagementClient = new PostgresManagementClient(PostgresTestBase.TestNpgsqlDataSource,
+            new PostgresConfiguration { MessageSerializer = new MicrosoftJsonSerializer() });
         await QueueInitializer.InitQueue(
             PostgresQueueName.Create(AutoMessageMapper.GetQueueName<TestCommand>()),
             PostgresTestBase.TestNpgsqlDataSource);

diff --git a/...stgresql/tests/KnightBus.PostgreSql.Tests.Integration/PostgresMessageStateHandlerTests.cs b/...stgresql/tests/KnightBus.PostgreSql.Tests.Integration/PostgresMessageStateHandlerTests.cs
@@ -14,7 +14,8 @@ public class PostgresMessageStateHandlerTests : MessageStateHandlerTests<Postgre
     public override async Task Setup()
     {
         _postgresManagementClient = new PostgresManagementClient(
-            PostgresTestBase.TestNpgsqlDataSource, new MicrosoftJsonSerializer());
+            PostgresTestBase.TestNpgsqlDataSource,
+            new PostgresConfiguration { MessageSerializer = new MicrosoftJsonSerializer() });
         _postgresQueueClient = new PostgresQueueClient<PostgresTestCommand>(
             PostgresTestBase.TestNpgsqlDataSource, new MicrosoftJsonSerializer());
         _bus = new PostgresBus(

diff --git a/...tbus-postgresql/tests/KnightBus.PostgreSql.Tests.Integration/PostgresQueueManagerTests.cs b/...tbus-postgresql/tests/KnightBus.PostgreSql.Tests.Integration/PostgresQueueManagerTests.cs
@@ -15,7 +15,8 @@ public class PostgresQueueManagerTests : QueueManagerTests<PostgresTestCommand>
 
     public override async Task Setup()
     {
-        _postgresManagementClient = new PostgresManagementClient(PostgresTestBase.TestNpgsqlDataSource, new MicrosoftJsonSerializer());
+        _postgresManagementClient = new PostgresManagementClient(PostgresTestBase.TestNpgsqlDataSource,
+            new PostgresConfiguration { MessageSerializer = new MicrosoftJsonSerializer() });
         _postgresQueueClient = new PostgresQueueClient<PostgresTestCommand>(PostgresTestBase.TestNpgsqlDataSource, new MicrosoftJsonSerializer());
         QueueManager = new PostgresQueueManager(_postgresManagementClient, new MicrosoftJsonSerializer());
         QueueType = QueueType.Queue;