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

INT-4383: Add test for EnricherSpec.errorChannel

Browse Source 
JIRA: https://jira.spring.io/browse/INT-4383
This commit is contained in:
Artem Bilan
2018-01-23 12:42:38 -05:00
parent 061dcb1b87
commit 9f6457fc31
1 changed files with 23 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
spring-integration-core/src/test/java/org/springframework/integration/dsl/transformers/TransformerTests.java
View File

@@ -54,7 +54,6 @@ import org.springframework.integration.dsl.channel.MessageChannels;
import org.springframework.integration.handler.advice.IdempotentReceiverInterceptor;
import org.springframework.integration.selector.MetadataStoreSelector;
import org.springframework.integration.support.MessageBuilder;
import org.springframework.integration.transformer.DecodingTransformer;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageHeaders;
@@ -87,6 +86,11 @@ public class TransformerTests {
@Qualifier("enricherInput3")
private FixedSubscriberChannel enricherInput3;
@Autowired
@Qualifier("enricherErrorChannel")
private PollableChannel enricherErrorChannel;
@Test
public void testContentEnricher() {
@@ -104,6 +108,11 @@ public class TransformerTests {
assertEquals("Bar Bar", result.getName());
assertNotNull(result.getDate());
assertThat(new Date(), Matchers.greaterThanOrEqualTo(result.getDate()));
this.enricherInput.send(new GenericMessage<>(new TestPojo("junk")));
Message<?> errorMessage = this.enricherErrorChannel.receive(10_000);
assertNotNull(errorMessage);
}
@Test
@@ -237,10 +246,16 @@ public class TransformerTests {
@EnableIntegration
public static class ContextConfiguration {
@Bean
public PollableChannel enricherErrorChannel() {
return new QueueChannel();
}
@Bean
public IntegrationFlow enricherFlow() {
return IntegrationFlows.from("enricherInput", true)
.enrich(e -> e.requestChannel("enrichChannel")
.errorChannel(enricherErrorChannel())
.requestPayloadExpression("payload")
.shouldClonePayload(false)
.propertyExpression("name", "payload['name']")
@@ -275,7 +290,12 @@ public class TransformerTests {
@Bean
public IntegrationFlow enrichFlow() {
return IntegrationFlows.from("enrichChannel")
.<TestPojo, Map<?, ?>>transform(p -> Collections.singletonMap("name", p.getName() + " Bar"))
.<TestPojo, Map<?, ?>>transform(p -> {
if ("junk".equals(p.getName())) {
throw new RuntimeException("intentional");
}
return Collections.singletonMap("name", p.getName() + " Bar");
})
.get();
}
@@ -298,10 +318,8 @@ public class TransformerTests {
@Bean
public IntegrationFlow decodingFlow() {
// TODO: Stored in an unnecessary variable to work around an eclipse type inference issue.
DecodingTransformer<Integer> transformer = Transformers.decoding(new MyCodec(), m -> Integer.class);
return f -> f
.transform(transformer)
.transform(Transformers.decoding(new MyCodec(), m -> Integer.class))
.channel("codecReplyChannel");
}