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

MessageHandlingExceptions (other than selector-rejection, handler-not-running, and executor-rejection) are now propagated from DefaultMessageDistributor (INT-184).

Browse Source
This commit is contained in:
Mark Fisher
2008-04-16 18:07:14 +00:00
parent 550a674850
commit 7edfc96f5e
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
spring-integration-core/src/main/java/org/springframework/integration/dispatcher/DefaultMessageDistributor.java
View File

@@ -27,9 +27,9 @@ import org.apache.commons.logging.LogFactory;
import org.springframework.integration.channel.DispatcherPolicy;
import org.springframework.integration.handler.MessageHandler;
import org.springframework.integration.handler.MessageHandlerNotRunningException;
import org.springframework.integration.handler.MessageHandlerRejectedExecutionException;
import org.springframework.integration.message.Message;
import org.springframework.integration.message.MessageDeliveryException;
import org.springframework.integration.message.MessageHandlingException;
import org.springframework.integration.message.selector.MessageSelectorRejectedException;
import org.springframework.util.Assert;
@@ -86,7 +86,7 @@ public class DefaultMessageDistributor implements MessageDistributor {
}
return false;
}
boolean encounteredHandlerException = false;
boolean rejected = false;
while (iter.hasNext()) {
MessageHandler handler = iter.next();
try {
@@ -98,22 +98,22 @@ public class DefaultMessageDistributor implements MessageDistributor {
}
catch (MessageSelectorRejectedException e) {
if (logger.isDebugEnabled()) {
logger.debug("selector rejected task, continuing with other handlers if available", e);
logger.debug("selector rejected message, continuing with other handlers if available", e);
}
}
catch (MessageHandlerNotRunningException e) {
if (logger.isDebugEnabled()) {
logger.debug("handler not running, continuing with other handlers if available", e);
}
}
}
catch (MessageHandlingException e) {
encounteredHandlerException = true;
catch (MessageHandlerRejectedExecutionException e) {
rejected = true;
if (logger.isDebugEnabled()) {
logger.debug("handler threw exception, continuing with other handlers if available", e);
logger.debug("handler is busy, continuing with other handlers if available", e);
}
}
}
if (!encounteredHandlerException) {
if (!rejected) {
return true;
}
attempts++;