From d220665bc76499134c5fdb3e9913df0541a2de0d Mon Sep 17 00:00:00 2001 From: Gary Russell Date: Fri, 30 Oct 2015 09:12:56 -0400 Subject: [PATCH] Cafe-DSL: Fix Deprecation --- .../integration/samples/dsl/cafe/nonlambda/Application.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/dsl/cafe-dsl/src/main/java/org/springframework/integration/samples/dsl/cafe/nonlambda/Application.java b/dsl/cafe-dsl/src/main/java/org/springframework/integration/samples/dsl/cafe/nonlambda/Application.java index c79c0779..c4c09718 100644 --- a/dsl/cafe-dsl/src/main/java/org/springframework/integration/samples/dsl/cafe/nonlambda/Application.java +++ b/dsl/cafe-dsl/src/main/java/org/springframework/integration/samples/dsl/cafe/nonlambda/Application.java @@ -99,10 +99,9 @@ public class Application { } @Bean - @SuppressWarnings("unchecked") public IntegrationFlow orders() { return IntegrationFlows.from("orders.input") - .split("payload.items", (Consumer) null) + .split("payload.items") .channel(MessageChannels.executor(Executors.newCachedThreadPool())) .route("payload.iced", new Consumer>() { @@ -176,7 +175,7 @@ public class Application { aggregatorSpec.processor(cafeAggregator, null); } - }, null) + }) .handle(CharacterStreamWritingMessageHandler.stdout()) .get(); }