diff --git a/src/Simplex/Messaging/Agent.hs b/src/Simplex/Messaging/Agent.hs
index 0dadd4795..001d551b0 100644
--- a/src/Simplex/Messaging/Agent.hs
+++ b/src/Simplex/Messaging/Agent.hs
@@ -65,7 +65,7 @@ module Simplex.Messaging.Agent
   )
 where
 
-import Control.Concurrent.STM (stateTVar)
+import Control.Concurrent.STM (flushTBQueue, stateTVar)
 import Control.Logger.Simple (logInfo, showText)
 import Control.Monad.Except
 import Control.Monad.IO.Unlift (MonadUnliftIO)
@@ -792,6 +792,7 @@ initializeNtfSubs c = do
 smpDeleteNtfSubs :: AgentMonad m => AgentClient -> m ()
 smpDeleteNtfSubs c = do
   ns <- asks ntfSupervisor
+  void . atomically . flushTBQueue $ ntfSubQ ns
   connIds <- atomically $ getSubscriptions c
   forM_ connIds $ \connId -> atomically $ writeTBQueue (ntfSubQ ns) (connId, NSCSmpDelete)