Allow ResendRequest to be sent through matrix

th2-net · Dec 13, 2024 · 92227f2 · 92227f2
1 parent 36712f7
commit 92227f2
Showing 1 changed file with 5 additions and 3 deletions.
diff --git 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<String, S
         FixField msgType = findField(message, MSG_TYPE_TAG, US_ASCII);
 
         if(msgType != null && ADMIN_MESSAGES.contains(msgType.getValue())) {
-            return;
+            if(!Objects.equals(msgType.getValue(), MSG_TYPE_RESEND_REQUEST)) {
+                return;
+            }
         }
 
         if (isEmpty(message)) {