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

INT-1696 updated tests for MessageProducerSupport

Browse Source
This commit is contained in:
Oleg Zhurakousky
2010-12-17 14:23:34 -05:00
parent 7ac078e706
commit 1d582583a5
1 changed files with 7 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
spring-integration-core/src/test/java/org/springframework/integration/endpoint/MessageProducerSupportTests.java
View File

@@ -22,7 +22,6 @@ import org.junit.Test;
import org.springframework.integration.Message;
import org.springframework.integration.MessageDeliveryException;
import org.springframework.integration.MessageHandlingException;
import org.springframework.integration.MessagingException;
import org.springframework.integration.channel.DirectChannel;
import org.springframework.integration.channel.PublishSubscribeChannel;
@@ -42,6 +41,7 @@ public class MessageProducerSupportTests {
@Test(expected=MessageDeliveryException.class)
public void validateExceptionIfNoErrorChannel() {
DirectChannel outChannel = new DirectChannel();
outChannel.subscribe(new MessageHandler() {
public void handleMessage(Message<?> message) throws MessagingException {
throw new RuntimeException("problems");
@@ -55,7 +55,7 @@ public class MessageProducerSupportTests {
mps.sendMessage(new GenericMessage<String>("hello"));
}
@Test(expected=MessageHandlingException.class)
@Test(expected=MessageDeliveryException.class)
public void validateExceptionIfSendToErrorChannelFails() {
DirectChannel outChannel = new DirectChannel();
outChannel.subscribe(new MessageHandler() {
@@ -64,9 +64,11 @@ public class MessageProducerSupportTests {
}
});
PublishSubscribeChannel errorChannel = new PublishSubscribeChannel();
ServiceActivatingHandler handler = new ServiceActivatingHandler(new FailingErrorService());
handler.afterPropertiesSet();
errorChannel.subscribe(handler);
errorChannel.subscribe(new MessageHandler() {
public void handleMessage(Message<?> message) throws MessagingException {
throw new RuntimeException("ooops");
}
});
MessageProducerSupport mps = new MessageProducerSupport() {};
mps.setOutputChannel(outChannel);
mps.setErrorChannel(errorChannel);
@@ -115,12 +117,4 @@ public class MessageProducerSupportTests {
}
}
private static class FailingErrorService {
@SuppressWarnings("unused")
public void handleErrorMessage(Message<?> errorMessage) {
throw new RuntimeException("ooops");
}
}
}