diff --git a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/ThreadAffinityClientConnectionFactory.java b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/ThreadAffinityClientConnectionFactory.java index eef7f3bd9a..1faa252d0a 100644 --- a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/ThreadAffinityClientConnectionFactory.java +++ b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/ThreadAffinityClientConnectionFactory.java @@ -298,21 +298,6 @@ public class ThreadAffinityClientConnectionFactory extends AbstractClientConnect this.connectionFactory.setMapper(mapper); } - @Override - public boolean isSingleUse() { - return this.connectionFactory.isSingleUse(); - } - - @Override - public void setSingleUse(boolean singleUse) { - this.connectionFactory.setSingleUse(singleUse); - } - - @Override - public void setLeaveOpen(boolean leaveOpen) { - this.connectionFactory.setLeaveOpen(leaveOpen); - } - @Override public void setInterceptorFactoryChain(TcpConnectionInterceptorFactoryChain interceptorFactoryChain) { this.connectionFactory.setInterceptorFactoryChain(interceptorFactoryChain); @@ -370,7 +355,7 @@ public class ThreadAffinityClientConnectionFactory extends AbstractClientConnect @Override public boolean closeConnection(String connectionId) { - return this.connectionFactory.closeConnection(connectionId); + return false; } @Override