Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

INT-1369 Improve Asynchrony of NIO Connections

Browse Source
This commit is contained in:
Gary Russell
2010-08-23 23:18:21 +00:00
parent 4090905770
commit 8571a12e20
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpNioConnection.java
View File

@@ -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