diff --git a/src/main/java/com/exactpro/th2/FixHandler.java b/src/main/java/com/exactpro/th2/FixHandler.java index 2306803..3572f29 100644 --- a/src/main/java/com/exactpro/th2/FixHandler.java +++ b/src/main/java/com/exactpro/th2/FixHandler.java @@ -855,7 +855,7 @@ public void sendResendRequest(int beginSeqNo, int endSeqNo, boolean isPossDup) { channel.send(Unpooled.wrappedBuffer(resendRequest.toString().getBytes(StandardCharsets.UTF_8)), strategy.getState().enrichProperties(), null, - SendMode.HANDLE_AND_MANGLE) + SendMode.MANGLE) .thenAcceptAsync(x -> strategy.getState().addMessageID(x), executorService); resetHeartbeatTask(); @@ -878,7 +878,7 @@ void sendResendRequest(int beginSeqNo) { //do private channel.send(Unpooled.wrappedBuffer(resendRequest.toString().getBytes(StandardCharsets.UTF_8)), strategy.getState().enrichProperties(), null, - SendMode.HANDLE_AND_MANGLE) + SendMode.MANGLE) .thenAcceptAsync(x -> strategy.getState().addMessageID(x), executorService); resetHeartbeatTask(); } @@ -1095,7 +1095,9 @@ public void onOutgoingUpdateTag(@NotNull ByteBuf message, @NotNull Map