We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent b7710fc commit 326e7acCopy full SHA for 326e7ac
src/reference/asciidoc/kotlin-dsl.adoc
@@ -49,7 +49,7 @@ This factory can be used in Kotlin as well:
49
----
50
@Bean
51
fun flowFromSupplier() =
52
- IntegrationFlows.from<String>({ "bar" }) { e -> e.poller { p -> p.fixedDelay(10).maxMessagesPerPoll(1) } }
+ IntegrationFlows.fromSupplier({ "bar" }) { e -> e.poller { p -> p.fixedDelay(10).maxMessagesPerPoll(1) } }
53
.channel { c -> c.queue("fromSupplierQueue") }
54
.get()
55
@@ -94,4 +94,3 @@ fun convertFlow() =
94
====
95
96
NOTE: The reified type can be a whole `Message<*>` if there need access to headers as well in the lambda of the operator.
97
-
0 commit comments