diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractEndpoint.java b/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractEndpoint.java
index 6f558ddf07..58a879f041 100644
--- a/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractEndpoint.java
+++ b/org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractEndpoint.java
@@ -32,7 +32,6 @@ import org.springframework.integration.message.MessageExchangeTemplate;
 import org.springframework.integration.message.MessageRejectedException;
 import org.springframework.integration.message.MessageSource;
 import org.springframework.integration.message.MessageTarget;
-import org.springframework.integration.message.MessagingException;
 import org.springframework.integration.message.selector.MessageSelector;
 import org.springframework.integration.scheduling.Schedule;
 
@@ -249,20 +248,6 @@ public abstract class AbstractEndpoint implements MessageEndpoint, ChannelRegist
 		return true;
 	}
 
-	public final boolean poll() {
-		if (this.messageExchangeTemplate == null) {
-			this.afterPropertiesSet();
-		}
-		if (this.source == null) {
-			throw new MessagingException("endpoint '" + this + "' has no source");
-		}
-		return this.messageExchangeTemplate.receiveAndForward(this.source, new MessageTarget() {
-			public boolean send(Message<?> message) {
-				return AbstractEndpoint.this.send(message, 0);
-			}
-		});
-	}
-
 	protected boolean supports(Message<?> message) {
 		if (this.selector != null && !this.selector.accept(message)) {
 			if (logger.isDebugEnabled()) {