From 8571a12e20554462bf9fdf0253ed65bca7fb8d53 Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Mon, 23 Aug 2010 23:18:21 +0000 Subject: [PATCH] INT-1369 Improve Asynchrony of NIO Connections --- .../integration/ip/tcp/connection/TcpNioConnection.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java index f723ab18ac..b9a1305d0c 100644 --- a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java +++ b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java @@ -164,6 +164,7 @@ public class TcpNioConnection extends AbstractTcpConnection { this.executionControl.incrementAndGet(); this.taskExecutor.execute(this); } + this.executionControl.decrementAndGet(); if (message != null) { sendToChannel(message); } @@ -172,7 +173,6 @@ public class TcpNioConnection extends AbstractTcpConnection { logger.error("Unexpected exception, exiting...", e); return; } - this.executionControl.decrementAndGet(); } finally { logger.trace("Nio message assembler exiting..."); // Final check in case new data came in and the