mirror of
https://github.com/simplex-chat/simplexmq.git
synced 2026-09-01 18:08:36 +00:00
Compare commits
4
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
4e4f8f2ad1 | ||
|
|
fef63f9083 | ||
|
|
457575f86f | ||
|
|
8647c24a95 |
+1
-1
@@ -1,7 +1,7 @@
|
|||||||
cabal-version: 1.12
|
cabal-version: 1.12
|
||||||
|
|
||||||
name: simplexmq
|
name: simplexmq
|
||||||
version: 6.2.1.0
|
version: 6.2.1.100
|
||||||
synopsis: SimpleXMQ message broker
|
synopsis: SimpleXMQ message broker
|
||||||
description: This package includes <./docs/Simplex-Messaging-Server.html server>,
|
description: This package includes <./docs/Simplex-Messaging-Server.html server>,
|
||||||
<./docs/Simplex-Messaging-Client.html client> and
|
<./docs/Simplex-Messaging-Client.html client> and
|
||||||
|
|||||||
@@ -221,13 +221,14 @@ getSMPAgentClient_ clientId cfg initServers@InitialAgentServers {smp, xftp} stor
|
|||||||
| backgroundMode = run c "subscriber" $ subscriber c
|
| backgroundMode = run c "subscriber" $ subscriber c
|
||||||
| otherwise = do
|
| otherwise = do
|
||||||
restoreServersStats c
|
restoreServersStats c
|
||||||
raceAny_
|
run c "subscriber" $ subscriber c
|
||||||
[ run c "subscriber" $ subscriber c,
|
-- raceAny_
|
||||||
run c "runNtfSupervisor" $ runNtfSupervisor c,
|
-- [ run c "subscriber" $ subscriber c
|
||||||
run c "cleanupManager" $ cleanupManager c,
|
-- run c "runNtfSupervisor" $ runNtfSupervisor c,
|
||||||
run c "logServersStats" $ logServersStats c
|
-- run c "cleanupManager" $ cleanupManager c,
|
||||||
]
|
-- run c "logServersStats" $ logServersStats c
|
||||||
`E.finally` saveServersStats c
|
-- ]
|
||||||
|
-- `E.finally` saveServersStats c
|
||||||
run AgentClient {subQ, acThread} name a =
|
run AgentClient {subQ, acThread} name a =
|
||||||
a `E.catchAny` \e -> whenM (isJust <$> readTVarIO acThread) $ do
|
a `E.catchAny` \e -> whenM (isJust <$> readTVarIO acThread) $ do
|
||||||
logError $ "Agent thread " <> name <> " crashed: " <> tshow e
|
logError $ "Agent thread " <> name <> " crashed: " <> tshow e
|
||||||
|
|||||||
Reference in New Issue
Block a user