diff --git a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpConnectionInterceptorSupport.java b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpConnectionInterceptorSupport.java index bad62d5295..844b102703 100644 --- a/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpConnectionInterceptorSupport.java +++ b/spring-integration-ip/src/main/java/org/springframework/integration/ip/tcp/connection/TcpConnectionInterceptorSupport.java @@ -96,6 +96,15 @@ public abstract class TcpConnectionInterceptorSupport extends TcpConnectionSuppo this.theConnection.registerSender(this); } + /** + * {@inheritDoc} + *
+ * IMPORTANT: Do not override this method in your interceptor implementation if the + * intercepted connection is created by a server connection factory, because the + * connection id of the underlying connection is used for routing when arbitrary + * outbound messaging is being used. The method is not final because client-side + * interceptors can override it without any issues. + */ @Override public String getConnectionId() { return this.theConnection.getConnectionId();