From 906880acf0fc72ca96c55db26f0027d5db475093 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Tue, 1 Jul 2014 14:49:53 +0300 Subject: [PATCH] DSL: Use `DelayerEndpointSpec` for `.delay()` GH: https://github.com/spring-projects/spring-integration-extensions/issues/84 --- .../integration/dsl/IntegrationFlowBuilder.java | 4 ++-- .../integration/dsl/test/IntegrationFlowTests.java | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/spring-integration-java-dsl/src/main/java/org/springframework/integration/dsl/IntegrationFlowBuilder.java b/spring-integration-java-dsl/src/main/java/org/springframework/integration/dsl/IntegrationFlowBuilder.java index b525a9d..424f294 100644 --- a/spring-integration-java-dsl/src/main/java/org/springframework/integration/dsl/IntegrationFlowBuilder.java +++ b/spring-integration-java-dsl/src/main/java/org/springframework/integration/dsl/IntegrationFlowBuilder.java @@ -256,12 +256,12 @@ public final class IntegrationFlowBuilder { } public IntegrationFlowBuilder delay(String groupId, String expression, - EndpointConfigurer> endpointConfigurer) { + EndpointConfigurer endpointConfigurer) { DelayHandler delayHandler = new DelayHandler(groupId); if (StringUtils.hasText(expression)) { delayHandler.setDelayExpression(PARSER.parseExpression(expression)); } - return this.register(new GenericEndpointSpec(delayHandler), endpointConfigurer); + return this.register(new DelayerEndpointSpec(delayHandler), endpointConfigurer); } public IntegrationFlowBuilder enrich(ComponentConfigurer enricherConfigurer) { diff --git a/spring-integration-java-dsl/src/test/java/org/springframework/integration/dsl/test/IntegrationFlowTests.java b/spring-integration-java-dsl/src/test/java/org/springframework/integration/dsl/test/IntegrationFlowTests.java index b0a0e7e..c8b3c7b 100644 --- a/spring-integration-java-dsl/src/test/java/org/springframework/integration/dsl/test/IntegrationFlowTests.java +++ b/spring-integration-java-dsl/src/test/java/org/springframework/integration/dsl/test/IntegrationFlowTests.java @@ -1226,13 +1226,13 @@ public class IntegrationFlowTests { return IntegrationFlows.from("bridgeFlow2Input") .bridge(c -> c.autoStartup(false).id("bridge")) .fixedSubscriberChannel() - .delay("delayer", "200", c -> c.advice(this.delayedAdvice)) + .delay("delayer", "200", c -> c.advice(this.delayedAdvice).messageStore(this.messageStore())) .channel(MessageChannels.queue("bridgeFlow2Output")) .get(); } @Bean - public MessageStore messageStore() { + public SimpleMessageStore messageStore() { return new SimpleMessageStore(); }