Make postgres subscription provider compatible with npgsql 8 (#6686)

Co-authored-by: Michael Staib <[email protected]>
ChilliCream · Nov 10, 2023 · 1cbb038 · 1cbb038
1 parent b6eb805
commit 1cbb038
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/src/HotChocolate/Core/src/Subscriptions.Postgres/PostgresChannelWriter.cs b/src/HotChocolate/Core/src/Subscriptions.Postgres/PostgresChannelWriter.cs
@@ -1,3 +1,4 @@
+using System.Data;
 using System.Threading.Channels;
 using HotChocolate.Subscriptions.Diagnostics;
 using Npgsql;
@@ -100,8 +101,16 @@ private async Task HandleMessage(NpgsqlConnection connection, CancellationToken
 
                 command.CommandText = "SELECT pg_notify(@channel, @message);";
 
-                command.Parameters.Add(new NpgsqlParameter("channel", _channelName));
-                command.Parameters.Add(new NpgsqlParameter("message", message.FormattedPayload));
+                var channel = new NpgsqlParameter("channel", DbType.String)
+                {
+                    Value = _channelName
+                };
+                var msg = new NpgsqlParameter("message", DbType.String)
+                {
+                    Value = message.FormattedPayload
+                };
+                command.Parameters.Add(channel);
+                command.Parameters.Add(msg);
 
                 batch.BatchCommands.Add(command);
             }