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

AbstractDispatcher now delegates to a TargetInvoker.

Browse Source
This commit is contained in:
Mark Fisher
2008-07-13 16:00:11 +00:00
parent 0efe7990d0
commit 6bc2ee1ff2
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
org.springframework.integration/src/main/java/org/springframework/integration/dispatcher/AbstractDispatcher.java
View File

@@ -23,9 +23,9 @@ import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.core.task.TaskExecutor;
import org.springframework.integration.message.BlockingTarget;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.MessageTarget;
import org.springframework.integration.message.TargetInvoker;
/**
* Base class for {@link MessageDispatcher} implementations.
@@ -42,6 +42,8 @@ public abstract class AbstractDispatcher implements MessageDispatcher {
private volatile TaskExecutor taskExecutor;
private final TargetInvoker targetInvoker = new TargetInvoker();
public void setTimeout(long timeout) {
this.timeout = timeout;
@@ -69,13 +71,7 @@ public abstract class AbstractDispatcher implements MessageDispatcher {
}
protected final boolean sendMessageToTarget(Message<?> message, MessageTarget target) {
boolean sent = (target instanceof BlockingTarget && this.timeout >= 0)
? ((BlockingTarget) target).send(message, this.timeout)
: target.send(message);
if (!sent && logger.isDebugEnabled()) {
logger.debug("dispatcher failed to send message to target '" + target + "'");
}
return sent;
return this.targetInvoker.invoke(target, message, this.timeout);
}
}