From 92227f21862ae878d7a888bb09044a358e501174 Mon Sep 17 00:00:00 2001 From: "denis.plotnikov" Date: Fri, 13 Dec 2024 09:37:17 +0300 Subject: [PATCH] Allow ResendRequest to be sent through matrix --- src/main/java/com/exactpro/th2/FixHandler.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) 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