Skip to content

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

[pgmq] safeSendMessage (which creates the queue)

parent 7b5d816f
Pipeline #6751 passed with stages
        in 11 minutes and 55 seconds
        Hide whitespace changes
        Inline Side-by-side
        Showing with 4 additions and 5 deletions
        cabal.project
        View file @ 58ab07e0
        ...@@ -8,7 +8,7 @@ packages: ...@@ -8,7 +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: 91f80083d6158d7a2543b394961cfef0417a1048 tag: 0591a643d8ba1776af4fac56c1e4ff5fc3e98bb3
        tests: true tests: true
        src/Async/Worker/Broker/PGMQ.hs
        View file @ 58ab07e0
        ...@@ -26,8 +26,7 @@ import Control.Concurrent.MVar (withMVar) ...@@ -26,8 +26,7 @@ import Control.Concurrent.MVar (withMVar)
        import Database.PostgreSQL.LibPQ qualified as LibPQ import Database.PostgreSQL.LibPQ qualified as LibPQ
        import Database.PostgreSQL.Simple qualified as PSQL import Database.PostgreSQL.Simple qualified as PSQL
        import Database.PostgreSQL.Simple.Internal qualified as PSQLInternal import Database.PostgreSQL.Simple.Internal qualified as PSQLInternal
        import Database.PGMQ.Simple qualified as PGMQ import Database.PGMQ qualified as PGMQ
        import Database.PGMQ.Types qualified as PGMQ
        data PGMQBroker data PGMQBroker
        ...@@ -105,8 +104,8 @@ instance (SerializableMessage a, Show a) => MessageBroker PGMQBroker a where ...@@ -105,8 +104,8 @@ instance (SerializableMessage a, Show a) => MessageBroker PGMQBroker a where
        setMessageTimeout (PGMQBroker' { conn }) (renderQueue -> queue) (PGMQMid msgId) (TimeoutS timeoutS) = setMessageTimeout (PGMQBroker' { conn }) (renderQueue -> queue) (PGMQMid msgId) (TimeoutS timeoutS) =
        PGMQ.setMessageVt conn queue msgId timeoutS PGMQ.setMessageVt conn queue msgId timeoutS
        sendMessage (PGMQBroker' { conn }) (renderQueue -> queue) (PGMQM message) = sendMessage (PGMQBroker' { conn }) (renderQueue -> queue) (PGMQM message) = do
        PGMQMid <$> PGMQ.sendMessage conn queue message 0 PGMQMid <$> PGMQ.safeSendMessage conn queue message 0
        deleteMessage (PGMQBroker' { conn }) (renderQueue -> queue) (PGMQMid msgId) = do deleteMessage (PGMQBroker' { conn }) (renderQueue -> queue) (PGMQMid msgId) = do
        PGMQ.deleteMessage conn queue msgId PGMQ.deleteMessage conn queue msgId
        ......
        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