Correct disable for outOfOrder

th2-net · Dec 13, 2024 · 6489460 · 6489460
1 parent 92227f2
commit 6489460
Showing 1 changed file with 5 additions and 4 deletions.
diff --git a/src/main/java/com/exactpro/th2/FixHandler.java b/src/main/java/com/exactpro/th2/FixHandler.java
@@ -1861,10 +1861,6 @@ private Map<String, String> missOutgoingMessages(ByteBuf message, Map<String, St
            && Duration.between(strategy.getStartTime(), Instant.now()).compareTo(strategy.getConfig().getDuration()) > 0 ) {
             strategy.disableAllowMessagesBeforeRetransmissionFinishes("after " + strategy.getConfig().getDuration() + " strategy duration");
         }
-        if(strategy.getOutOfOrder()
-                && Duration.between(strategy.getStartTime(), Instant.now()).compareTo(strategy.getConfig().getDuration()) > 0 ) {
-            strategy.disableOutOfOrder("after " + strategy.getConfig().getDuration() + " strategy duration");
-        }
 
         return null;
     }
@@ -2633,6 +2629,11 @@ private void recoveryFromState(Integer beginSeqNo, Integer endSeqNo) {
 
         LOGGER.info("Making recovery from state: {} - {}.", beginSeqNo, endSeqNo);
 
+        if(strategy.getOutOfOrder()
+                && Duration.between(strategy.getStartTime(), Instant.now()).compareTo(strategy.getConfig().getDuration()) > 0 ) {
+            strategy.disableOutOfOrder("after " + strategy.getConfig().getDuration() + " strategy duration");
+        }
+
         boolean skip = strategy.getOutOfOrder();
         ByteBuf skipped = null;