DefaultMessageBus now sets channelRegistry only when activating endpoints (not when registering).
This commit is contained in:
@@ -214,9 +214,6 @@ public class DefaultMessageBus implements MessageBus, ApplicationContextAware, A
|
||||
}
|
||||
|
||||
public void registerEndpoint(MessageEndpoint endpoint) {
|
||||
if (endpoint instanceof ChannelRegistryAware) {
|
||||
((ChannelRegistryAware) endpoint).setChannelRegistry(this);
|
||||
}
|
||||
this.endpointRegistry.registerEndpoint(endpoint);
|
||||
if (this.isRunning()) {
|
||||
this.activateEndpoint(endpoint);
|
||||
|
||||
Reference in New Issue
Block a user