fix

th2-net · Nov 29, 2023 · cade01e · cade01e
1 parent 4e8d305
commit cade01e
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/src/main/java/com/exactpro/th2/FixHandler.java b/src/main/java/com/exactpro/th2/FixHandler.java
@@ -401,7 +401,7 @@ public CompletableFuture<MessageID> send(@NotNull ByteBuf body, @NotNull Map<Str
                 }
             }
         } else {
-            while (channel.isOpen() && !enabled.get()) {
+            while (!enabled.get()) {
                 if (LOGGER.isWarnEnabled()) LOGGER.warn("Session is not yet logged in: {}", channel.getSessionAlias());
                 try {
                     //noinspection BusyWait
@@ -712,6 +712,12 @@ private Map<String, String> handleLogout(@NotNull ByteBuf message, Map<String, S
         cancelFuture(testRequestTimer);
         enabled.set(false);
         context.send(CommonUtil.toEvent("logout for sender - " + settings.getSenderCompID()), null);//make more useful
+        try {
+            disconnect(false);
+            channel.open();
+        } catch (Exception e) {
+            LOGGER.error("Error while disconnecting in handle logout.");
+        }
         return metadata;
     }