core: 6.2.0.0 (simplexmq: 6.2.0.3)

This commit is contained in:
Evgeny Poberezkin
2024-11-17 10:25:03 +00:00
parent e45a96935c
commit 6843269cff
6 changed files with 9 additions and 7 deletions
+3 -1
View File
@@ -439,6 +439,8 @@ smpServerCfg =
controlPortUserAuth = Nothing,
controlPortAdminAuth = Nothing,
messageExpiration = Just defaultMessageExpiration,
expireMessagesOnStart = False,
idleQueueInterval = defaultIdleQueueInterval,
notificationExpiration = defaultNtfExpiration,
inactiveClientExpiration = Just defaultInactiveClientExpiration,
smpCredentials =
@@ -524,7 +526,7 @@ serverBracket server f = do
started <- newEmptyTMVarIO
bracket
(forkIOWithUnmask ($ server started))
(\t -> killThread t >> waitFor started "stop")
(\t -> killThread t >> waitFor started "stop" >> threadDelay 100000)
(\_ -> waitFor started "start" >> f)
where
waitFor started s =