From 8e3d520b7634cb8ff52b914347ae5bf1334400f9 Mon Sep 17 00:00:00 2001 From: Glenn Renfro Date: Fri, 21 Nov 2025 11:04:05 -0500 Subject: [PATCH] Simplify Kotlin DSL for MessageSource integration flows Remove explicit MessageProcessorMessageSource wrapper in favor of direct lambda usage in integrationFlow() calls. This makes the Kotlin DSL more idiomatic by leveraging Kotlin's function type inference, aligning with the language's conventions for functional interfaces. --- src/reference/antora/modules/ROOT/pages/kotlin-dsl.adoc | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/reference/antora/modules/ROOT/pages/kotlin-dsl.adoc b/src/reference/antora/modules/ROOT/pages/kotlin-dsl.adoc index d1a9953838..d8488bcd9e 100644 --- a/src/reference/antora/modules/ROOT/pages/kotlin-dsl.adoc +++ b/src/reference/antora/modules/ROOT/pages/kotlin-dsl.adoc @@ -65,7 +65,7 @@ fun functionFlow() = @Bean fun messageSourceFlow() = - integrationFlow(MessageProcessorMessageSource { "testSource" }, + integrationFlow({ "testSource" }, { poller { it.fixedDelay(10).maxMessagesPerPoll(1) } }) { channel { queue("fromSupplierQueue") } }