From 3144927e178d46713c16cdc86d5acce615bc64c7 Mon Sep 17 00:00:00 2001
From: "denis.plotnikov" <denis.plotnikov@exactprosystems.com>
Date: Mon, 16 Dec 2024 17:48:08 +0300
Subject: [PATCH] More time to get a response on ResendRequest on logout.

---
 src/main/java/com/exactpro/th2/FixHandler.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/src/main/java/com/exactpro/th2/FixHandler.java b/src/main/java/com/exactpro/th2/FixHandler.java
index 0e51c90..52749df 100644
--- 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));