Skip to content

Commit

Permalink
Linter
Browse files Browse the repository at this point in the history
  • Loading branch information
pcapriotti committed Dec 10, 2024
1 parent fac4184 commit 6238075
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion services/cannon/src/Cannon/RabbitMq.hs
Original file line number Diff line number Diff line change
Expand Up @@ -165,6 +165,9 @@ createConnection pool = mask_ $ do
void . async $ do
v <- race (takeMVar closedVar) (readMVar pool.deadVar)
when (isRight v) $
-- close connection and ignore exceptions
-- close connection and ignore exceptions

-- close connection and ignore exceptions
catch @SomeException (Q.closeConnection conn) $
\_ -> pure ()
Expand All @@ -182,7 +185,7 @@ openConnection pool = do
-- assigned to this connection, since there are potential races with other
-- connections being opened at the same time. However, this is only used to
-- name the connection, and we only rely on names for tests, so it is fine.
connId <- atomically $ readTVar pool.nextId
connId <- readTVarIO pool.nextId
(username, password) <- readCredsFromEnv
recovering
rabbitMqRetryPolicy
Expand Down

0 comments on commit 6238075

Please sign in to comment.