Cafe-DSL: Fix Deprecation

This commit is contained in:
Gary Russell
2015-10-30 09:12:56 -04:00
parent 76efa61056
commit d220665bc7

View File

@@ -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<RouterSpec<ExpressionEvaluatingRouter>>() {
@@ -176,7 +175,7 @@ public class Application {
aggregatorSpec.processor(cafeAggregator, null);
}
}, null)
})
.handle(CharacterStreamWritingMessageHandler.stdout())
.get();
}