Skip to content

H
haskell-bee
Verified Commit 7b5d816f authored by Przemyslaw Kaminski's avatar Przemyslaw Kaminski
Browse files
Options

[pgmq] initialize broker, it now can create schema automatically

parent 70b86467
Pipeline #6743 failed with stages
        in 11 minutes and 20 seconds
        Hide whitespace changes
        Inline Side-by-side
        Showing with 3 additions and 2 deletions
        cabal.project
        View file @ 7b5d816f
        ...@@ -8,6 +8,7 @@ packages: ...@@ -8,6 +8,7 @@ packages:
        source-repository-package source-repository-package
        type: git type: git
        location: https://gitlab.iscpif.fr/gargantext/haskell-pgmq location: https://gitlab.iscpif.fr/gargantext/haskell-pgmq
        tag: fcb7d4fb811e5b7239078b48268c469c8d28fdf9 tag: 91f80083d6158d7a2543b394961cfef0417a1048
        tests: true tests: true
        src/Async/Worker/Broker/PGMQ.hs
        View file @ 7b5d816f
        ...@@ -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