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

Removed poll() method from AbstractEndpoint.

Browse Source
This commit is contained in:
Mark Fisher
2008-07-30 01:37:21 +00:00
parent 4a808803b9
commit a8075554ed
1 changed files with 0 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
org.springframework.integration/src/main/java/org/springframework/integration/endpoint/AbstractEndpoint.java
View File

@@ -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()) {