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

Renamed RootCauseErrorMessageRouter to the more appropriate ErrorMessageExceptionTypeRouter (the routing is actually based on the most-specific Exception type available in the exceptionTypeChannelMap).

Browse Source
This commit is contained in:
Mark Fisher
2008-10-10 23:58:27 +00:00
parent 045011318e
commit ec91ae8f08
2 changed files with 9 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
org.springframework.integration/src/test/java/org/springframework/integration/router/RootCauseErrorMessageRouterTests.java → org.springframework.integration/src/test/java/org/springframework/integration/router/ErrorMessageExceptionTypeRouterTests.java
View File

@@ -36,7 +36,7 @@ import org.springframework.integration.message.StringMessage;
/**
* @author Mark Fisher
*/
public class RootCauseErrorMessageRouterTests {
public class ErrorMessageExceptionTypeRouterTests {
private QueueChannel illegalArgumentChannel = new QueueChannel();
@@ -56,7 +56,7 @@ public class RootCauseErrorMessageRouterTests {
RuntimeException middleCause = new RuntimeException(rootCause);
MessageHandlingException error = new MessageHandlingException(failedMessage, "failed", middleCause);
ErrorMessage message = new ErrorMessage(error);
RootCauseErrorMessageRouter router = new RootCauseErrorMessageRouter();
ErrorMessageExceptionTypeRouter router = new ErrorMessageExceptionTypeRouter();
Map<Class<? extends Throwable>, MessageChannel> exceptionTypeChannelMap =
new HashMap<Class<? extends Throwable>, MessageChannel>();
exceptionTypeChannelMap.put(IllegalArgumentException.class, illegalArgumentChannel);
@@ -78,7 +78,7 @@ public class RootCauseErrorMessageRouterTests {
RuntimeException middleCause = new RuntimeException(rootCause);
MessageHandlingException error = new MessageHandlingException(failedMessage, "failed", middleCause);
ErrorMessage message = new ErrorMessage(error);
RootCauseErrorMessageRouter router = new RootCauseErrorMessageRouter();
ErrorMessageExceptionTypeRouter router = new ErrorMessageExceptionTypeRouter();
Map<Class<? extends Throwable>, MessageChannel> exceptionTypeChannelMap =
new HashMap<Class<? extends Throwable>, MessageChannel>();
exceptionTypeChannelMap.put(RuntimeException.class, runtimeExceptionChannel);
@@ -99,7 +99,7 @@ public class RootCauseErrorMessageRouterTests {
RuntimeException middleCause = new RuntimeException(rootCause);
MessageHandlingException error = new MessageHandlingException(failedMessage, "failed", middleCause);
ErrorMessage message = new ErrorMessage(error);
RootCauseErrorMessageRouter router = new RootCauseErrorMessageRouter();
ErrorMessageExceptionTypeRouter router = new ErrorMessageExceptionTypeRouter();
Map<Class<? extends Throwable>, MessageChannel> exceptionTypeChannelMap =
new HashMap<Class<? extends Throwable>, MessageChannel>();
exceptionTypeChannelMap.put(MessageHandlingException.class, messageHandlingExceptionChannel);
@@ -119,7 +119,7 @@ public class RootCauseErrorMessageRouterTests {
RuntimeException middleCause = new RuntimeException(rootCause);
MessageHandlingException error = new MessageHandlingException(failedMessage, "failed", middleCause);
ErrorMessage message = new ErrorMessage(error);
RootCauseErrorMessageRouter router = new RootCauseErrorMessageRouter();
ErrorMessageExceptionTypeRouter router = new ErrorMessageExceptionTypeRouter();
router.setDefaultOutputChannel(defaultChannel);
router.onMessage(message);
assertNotNull(defaultChannel.receive(1000));
@@ -135,7 +135,7 @@ public class RootCauseErrorMessageRouterTests {
RuntimeException middleCause = new RuntimeException(rootCause);
MessageHandlingException error = new MessageHandlingException(failedMessage, "failed", middleCause);
ErrorMessage message = new ErrorMessage(error);
RootCauseErrorMessageRouter router = new RootCauseErrorMessageRouter();
ErrorMessageExceptionTypeRouter router = new ErrorMessageExceptionTypeRouter();
Map<Class<? extends Throwable>, MessageChannel> exceptionTypeChannelMap =
new HashMap<Class<? extends Throwable>, MessageChannel>();
exceptionTypeChannelMap.put(MessageDeliveryException.class, messageDeliveryExceptionChannel);
@@ -151,7 +151,7 @@ public class RootCauseErrorMessageRouterTests {
RuntimeException middleCause = new RuntimeException(rootCause);
MessageHandlingException error = new MessageHandlingException(failedMessage, "failed", middleCause);
Message<?> message = new GenericMessage<Exception>(error);
RootCauseErrorMessageRouter router = new RootCauseErrorMessageRouter();
ErrorMessageExceptionTypeRouter router = new ErrorMessageExceptionTypeRouter();
Map<Class<? extends Throwable>, MessageChannel> exceptionTypeChannelMap =
new HashMap<Class<? extends Throwable>, MessageChannel>();
exceptionTypeChannelMap.put(IllegalArgumentException.class, illegalArgumentChannel);
@@ -173,7 +173,7 @@ public class RootCauseErrorMessageRouterTests {
RuntimeException middleCause = new RuntimeException(rootCause);
MessageHandlingException error = new MessageHandlingException(failedMessage, "failed", middleCause);
ErrorMessage message = new ErrorMessage(error);
RootCauseErrorMessageRouter router = new RootCauseErrorMessageRouter();
ErrorMessageExceptionTypeRouter router = new ErrorMessageExceptionTypeRouter();
Map<Class<? extends Throwable>, MessageChannel> exceptionTypeChannelMap =
new HashMap<Class<? extends Throwable>, MessageChannel>();
exceptionTypeChannelMap.put(IllegalArgumentException.class, illegalArgumentChannel);