More time to get a response on ResendRequest on logout.

th2-net · Dec 16, 2024 · 3144927 · 3144927
1 parent 6489460
commit 3144927
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/main/java/com/exactpro/th2/FixHandler.java b/src/main/java/com/exactpro/th2/FixHandler.java
@@ -797,7 +797,7 @@ private Map<String, String> handleLogout(@NotNull ByteBuf message, Map<String, S
         context.send(CommonUtil.toEvent("logout for sender - " + settings.getSenderCompID()), null);//make more useful
         try {
             if(strategy.getSendResendRequestOnLogoutReply()) {
-                Thread.sleep(1000);
+                Thread.sleep(3000);
             }
             disconnect(false);
             openChannel();
@@ -1795,7 +1795,7 @@ private Map<String, String> fakeRetransmissionOutgoingProcessor(ByteBuf message,
             return null;
         }
 
-        channel.send(Unpooled.copiedBuffer(message), metadata, null, SendMode.DIRECT);
+        channel.send(asExpandable(Unpooled.copiedBuffer(message)), metadata, null, SendMode.DIRECT);
 
         FixField sendingTime = requireNonNull(findField(message, SENDING_TIME_TAG));
         strategy.getState().addMissedMessageToCacheIfCondition(msgSeqNum.get(), message.copy(), x -> true);
@@ -1820,7 +1820,7 @@ private Map<String, String> possDupOutgoingProcessor(ByteBuf message, Map<String
             return null;
         }
 
-        channel.send(Unpooled.copiedBuffer(message), metadata, null, SendMode.DIRECT);
+        channel.send(asExpandable(Unpooled.copiedBuffer(message)), metadata, null, SendMode.DIRECT);
 
         FixField sendingTime = requireNonNull(findField(message, SENDING_TIME_TAG));