diff --git a/spring-integration-core/src/main/java/org/springframework/integration/router/RouterMessageHandlerAdapter.java b/spring-integration-core/src/main/java/org/springframework/integration/router/RouterMessageHandlerAdapter.java index d86e43ab75..d805f556f6 100644 --- a/spring-integration-core/src/main/java/org/springframework/integration/router/RouterMessageHandlerAdapter.java +++ b/spring-integration-core/src/main/java/org/springframework/integration/router/RouterMessageHandlerAdapter.java @@ -44,11 +44,11 @@ public class RouterMessageHandlerAdapter extends AbstractMessageHandlerAdapter i private static final String ATTRIBUTE_KEY = "attribute"; - private Method method; + private final Method method; - private Map attributes; + private final Map attributes; - private ChannelRegistry channelRegistry; + private volatile ChannelRegistry channelRegistry; public RouterMessageHandlerAdapter(Object object, Method method, Map attributes) {