diff --git a/src/Simplex/Messaging/Agent/NtfSubSupervisor.hs b/src/Simplex/Messaging/Agent/NtfSubSupervisor.hs index ff728eac3..95b1bc61b 100644 --- a/src/Simplex/Messaging/Agent/NtfSubSupervisor.hs +++ b/src/Simplex/Messaging/Agent/NtfSubSupervisor.hs @@ -59,6 +59,7 @@ runNtfSupervisor :: AgentClient -> AM' () runNtfSupervisor c = do ns <- asks ntfSupervisor forever $ do + logInfo "#################### runNtfSupervisor - in forever loop" cmd <- atomically . readTBQueue $ ntfSubQ ns handleErr . agentOperationBracket c AONtfNetwork waitUntilActive $ runExceptT (processNtfCmd c cmd) >>= \case @@ -196,6 +197,7 @@ withTokenServer action = lift getNtfToken >>= mapM_ (\NtfToken {ntfServer} -> ac runNtfWorker :: AgentClient -> NtfServer -> Worker -> AM () runNtfWorker c srv Worker {doWork} = forever $ do + logInfo "#################### runNtfWorker - in forever loop" waitForWork doWork ExceptT $ agentOperationBracket c AONtfNetwork throwWhenInactive $ runExceptT runNtfOperation where @@ -364,6 +366,7 @@ runNtfWorker c srv Worker {doWork} = runNtfSMPWorker :: AgentClient -> SMPServer -> Worker -> AM () runNtfSMPWorker c srv Worker {doWork} = forever $ do + logInfo "#################### runNtfSMPWorker - in forever loop" waitForWork doWork ExceptT $ agentOperationBracket c AONtfNetwork throwWhenInactive $ runExceptT runNtfSMPOperation where