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

Removed getTrigger() method from MessageEndpoint (avoids a tangle). It is not yet used.

Browse Source
This commit is contained in:
Mark Fisher
2008-07-07 01:43:59 +00:00
parent c7250f3ea5
commit 69e18fcf95
2 changed files with 1 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
org.springframework.integration/src/main/java/org/springframework/integration/bus/DefaultMessageBus.java
View File

@@ -342,10 +342,7 @@ public class DefaultMessageBus implements MessageBus, ApplicationContextAware, A
return;
}
Schedule schedule = endpoint.getSchedule();
EndpointTrigger trigger = endpoint.getTrigger();
if (trigger == null) {
trigger = new EndpointTrigger(schedule != null ? schedule : this.defaultPollerSchedule);
}
EndpointTrigger trigger = new EndpointTrigger(schedule != null ? schedule : this.defaultPollerSchedule);
trigger.addTarget(endpoint);
if (this.endpointTriggers.add(trigger)) {
this.taskScheduler.schedule(trigger);

2
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/MessageEndpoint.java
View File

@@ -35,8 +35,6 @@ public interface MessageEndpoint extends MessageTarget, ChannelRegistryAware, In
Schedule getSchedule();
EndpointTrigger getTrigger();
String getInputChannelName();
MessageChannel getInputChannel();