diff --git a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/AbstractConnectionFactory.java b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/AbstractConnectionFactory.java index 22f25e9a60..efb4b86bb6 100644 --- a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/AbstractConnectionFactory.java +++ b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/AbstractConnectionFactory.java @@ -325,8 +325,12 @@ public abstract class AbstractConnectionFactory if (this.interceptorFactoryChain == null) { return connection; } - for (TcpConnectionInterceptorFactory factory : - this.interceptorFactoryChain.getInterceptorFactories()) { + TcpConnectionInterceptorFactory[] interceptorFactories = + this.interceptorFactoryChain.getInterceptorFactories(); + if (interceptorFactories == null) { + return connection; + } + for (TcpConnectionInterceptorFactory factory : interceptorFactories) { TcpConnectionInterceptor wrapper = factory.getInterceptor(); wrapper.setTheConnection(connection); // if no ultimate listener or sender, register each wrapper in turn