diff --git a/src/ATrade/Broker/Client.hs b/src/ATrade/Broker/Client.hs
index 1a9a130..f52caf0 100644
--- a/src/ATrade/Broker/Client.hs
+++ b/src/ATrade/Broker/Client.hs
@@ -188,7 +188,7 @@ notificationThread clientIdentity callbacks ctx ep idCounter cmdVar killMv secPa
                   when (getNotificationSqnum notification /= currentSqnum) $ do
                     log Warning "Broker.Client" $
                              "Notification sqnum mismatch: " <> (T.pack . show) currentSqnum <> " -> " <> (T.pack . show) (getNotificationSqnum notification)
-                  atomicWriteIORef notifSqnumRef (nextSqnum currentSqnum)
+                  atomicWriteIORef notifSqnumRef (nextSqnum $ getNotificationSqnum notification)
                   forM_ callbacks $ \c -> c notification
                   atomicWriteIORef lastKnownNotificationSqnum currentSqnum
                 _                 -> return ()