[pgmq] don't initialize extension

parent 09e12397
Pipeline #6735 failed with stages
in 13 minutes and 22 seconds
...@@ -58,7 +58,7 @@ instance (SerializableMessage a, Show a) => MessageBroker PGMQBroker a where ...@@ -58,7 +58,7 @@ instance (SerializableMessage a, Show a) => MessageBroker PGMQBroker a where
-- https://www.postgresql.org/docs/current/libpq-notice-processing.html -- https://www.postgresql.org/docs/current/libpq-notice-processing.html
withMVar (PSQLInternal.connectionHandle conn) $ \c -> do withMVar (PSQLInternal.connectionHandle conn) $ \c -> do
LibPQ.disableNoticeReporting c LibPQ.disableNoticeReporting c
PGMQ.initialize conn -- PGMQ.initialize conn
pure $ PGMQBroker' { conn, defaultVt } pure $ PGMQBroker' { conn, defaultVt }
deinitBroker (PGMQBroker' { conn }) = PSQL.close conn deinitBroker (PGMQBroker' { conn }) = PSQL.close conn
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment