Spring/spring-integration
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Removed the registerEndpoint method from MessageBus.

Browse Source
This commit is contained in:
Mark Fisher
2008-10-31 21:21:42 +00:00
parent cb25a95280
commit 14d892e044
4 changed files with 2 additions and 18 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
org.springframework.integration/src/main/java/org/springframework/integration/bus/ApplicationContextMessageBus.java
View File

@@ -100,19 +100,6 @@ public class ApplicationContextMessageBus implements MessageBus, ChannelResolver
return this.channelResolver.resolveChannelName(channelName);
}
public void registerEndpoint(MessageEndpoint endpoint) {
Assert.notNull(endpoint, "'endpoint' must not be null");
if (!this.endpoints.contains(endpoint)) {
this.endpoints.add(endpoint);
}
if (this.isRunning()) {
this.activateEndpoint(endpoint);
}
if (logger.isInfoEnabled()) {
logger.info("registered endpoint '" + endpoint + "'");
}
}
private Collection<MessageEndpoint> getEndpoints() {
GenericBeanFactoryAccessor accessor = new GenericBeanFactoryAccessor(this.applicationContext);
this.endpoints.addAll(accessor.getBeansOfType(MessageEndpoint.class).values());

3
org.springframework.integration/src/main/java/org/springframework/integration/bus/MessageBus.java
View File

@@ -17,7 +17,6 @@
package org.springframework.integration.bus;
import org.springframework.context.Lifecycle;
import org.springframework.integration.endpoint.MessageEndpoint;
/**
* The message bus interface.
@@ -26,6 +25,4 @@ import org.springframework.integration.endpoint.MessageEndpoint;
*/
public interface MessageBus extends Lifecycle {
void registerEndpoint(MessageEndpoint endpoint);
}

2
org.springframework.integration/src/main/java/org/springframework/integration/bus/MessageBusStartedEvent.java
View File

@@ -30,7 +30,7 @@ public class MessageBusStartedEvent extends ApplicationEvent {
* @param source the <code>MessageBus</code> that has been started
* (must not be <code>null</code>)
*/
public MessageBusStartedEvent(MessageBus source) {
public MessageBusStartedEvent(Object source) {
super(source);
}

2
org.springframework.integration/src/main/java/org/springframework/integration/bus/MessageBusStoppedEvent.java
View File

@@ -30,7 +30,7 @@ public class MessageBusStoppedEvent extends ApplicationEvent {
* @param source the <code>MessageBus</code> that has been stopped
* (must not be <code>null</code>)
*/
public MessageBusStoppedEvent(MessageBus source) {
public MessageBusStoppedEvent(Object source) {
super(source);
}