From 4e8d305e616befa11591f7f7b35d9410c9dc44f3 Mon Sep 17 00:00:00 2001 From: Denis Plotnikov Date: Wed, 29 Nov 2023 22:24:39 +0400 Subject: [PATCH] fix --- src/main/java/com/exactpro/th2/FixHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/com/exactpro/th2/FixHandler.java b/src/main/java/com/exactpro/th2/FixHandler.java index 3b59409..c2abe6b 100644 --- a/src/main/java/com/exactpro/th2/FixHandler.java +++ b/src/main/java/com/exactpro/th2/FixHandler.java @@ -886,7 +886,7 @@ private void recovery(int beginSeqNo, int endSeqNo, RecoveryConfig recoveryConfi processMessage ); - if(lastProcessedSequence.get() < endSeq) { + if(lastProcessedSequence.get() < endSeq && msgSeqNum.get() + 1 != lastProcessedSequence.get() + 1) { String seqReset = createSequenceReset(Math.max(lastProcessedSequence.get() + 1, beginSeqNo), msgSeqNum.get() + 1).toString(); channel.send( Unpooled.wrappedBuffer(seqReset.getBytes(StandardCharsets.UTF_8)),