diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/bus/DefaultMessageBus.java b/org.springframework.integration/src/main/java/org/springframework/integration/bus/DefaultMessageBus.java
index e2252d7da6..2541e0a469 100644
--- a/org.springframework.integration/src/main/java/org/springframework/integration/bus/DefaultMessageBus.java
+++ b/org.springframework.integration/src/main/java/org/springframework/integration/bus/DefaultMessageBus.java
@@ -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);
diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/MessageEndpoint.java b/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/MessageEndpoint.java
index 810cc2c1ce..846502d0f9 100644
--- a/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/MessageEndpoint.java
+++ b/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/MessageEndpoint.java
@@ -35,8 +35,6 @@ public interface MessageEndpoint extends MessageTarget, ChannelRegistryAware, In
 
 	Schedule getSchedule();
 
-	EndpointTrigger getTrigger();
-
 	String getInputChannelName();
 
 	MessageChannel getInputChannel();