diff --git a/src/main/kotlin/com/exactpro/th2/conn/dirty/fix/MessageLoader.kt b/src/main/kotlin/com/exactpro/th2/conn/dirty/fix/MessageLoader.kt index 75e5ba1..c87112b 100644 --- a/src/main/kotlin/com/exactpro/th2/conn/dirty/fix/MessageLoader.kt +++ b/src/main/kotlin/com/exactpro/th2/conn/dirty/fix/MessageLoader.kt @@ -156,7 +156,7 @@ class MessageLoader( val buf = Unpooled.copiedBuffer(message.bodyRaw.toByteArray()) val sequence = buf.findField(MSG_SEQ_NUM_TAG)?.value?.toInt() ?: continue - if(sequence == 1 && lastProcessedSequence > 1 || sequence == 2 && lastProcessedSequence > 2) { + if(sequence > 1 && lastProcessedSequence == 1 || sequence > 2 && lastProcessedSequence == 2) { skipRetransmission = true return@withCancellation }