diff --git a/knightbus-postgresql/src/KnightBus.PostgreSql.Management/KnightBus.PostgreSql.Management.csproj b/knightbus-postgresql/src/KnightBus.PostgreSql.Management/KnightBus.PostgreSql.Management.csproj
index 04697ad4..9b053981 100644
--- a/knightbus-postgresql/src/KnightBus.PostgreSql.Management/KnightBus.PostgreSql.Management.csproj
+++ b/knightbus-postgresql/src/KnightBus.PostgreSql.Management/KnightBus.PostgreSql.Management.csproj
@@ -11,7 +11,7 @@
https://raw.githubusercontent.com/BookBeat/knightbus/master/documentation/media/images/knighbus-64.png
knighbus-64.png
https://github.com/BookBeat/knightbus
- 1.3.1
+ 1.3.2
knightbus;postgresql;queues;messaging
latest
enable
diff --git a/knightbus-postgresql/src/KnightBus.PostgreSql.Management/PostgresManagementClient.cs b/knightbus-postgresql/src/KnightBus.PostgreSql.Management/PostgresManagementClient.cs
index 62658c70..63419551 100644
--- a/knightbus-postgresql/src/KnightBus.PostgreSql.Management/PostgresManagementClient.cs
+++ b/knightbus-postgresql/src/KnightBus.PostgreSql.Management/PostgresManagementClient.cs
@@ -1,5 +1,6 @@
using System.Runtime.CompilerServices;
using KnightBus.Messages;
+using Microsoft.Extensions.DependencyInjection;
using Npgsql;
using NpgsqlTypes;
using static KnightBus.PostgreSql.PostgresConstants;
@@ -11,7 +12,7 @@ public class PostgresManagementClient
private readonly NpgsqlDataSource _npgsqlDataSource;
private readonly IMessageSerializer _serializer;
- public PostgresManagementClient(NpgsqlDataSource npgsqlDataSource, IPostgresConfiguration configuration)
+ public PostgresManagementClient([FromKeyedServices(NpgsqlDataSourceContainerKey)] NpgsqlDataSource npgsqlDataSource, IPostgresConfiguration configuration)
{
_npgsqlDataSource = npgsqlDataSource;
_serializer = configuration.MessageSerializer;
diff --git a/knightbus-postgresql/src/KnightBus.PostgreSql/PostgresConstants.cs b/knightbus-postgresql/src/KnightBus.PostgreSql/PostgresConstants.cs
index d8839ba5..c167bd36 100644
--- a/knightbus-postgresql/src/KnightBus.PostgreSql/PostgresConstants.cs
+++ b/knightbus-postgresql/src/KnightBus.PostgreSql/PostgresConstants.cs
@@ -7,6 +7,6 @@ public static class PostgresConstants
public const string SubscriptionPrefix = "s";
public const string DlQueuePrefix = "dlq";
public const string SchemaName = "knightbus";
-
- internal const string NpgsqlDataSourceContainerKey = "knightbus-postgres";
+
+ public const string NpgsqlDataSourceContainerKey = "knightbus-postgres";
}