public final class IntegrationFlowBuilder extends IntegrationFlowDefinition<IntegrationFlowBuilder>
BaseIntegrationFlowDefinition.ReplyProducerCleaner
integrationComponents, PARSER
Modifier and Type | Method and Description |
---|---|
StandardIntegrationFlow |
get() |
<T> org.reactivestreams.Publisher<Message<T>> |
toReactivePublisher()
Represent an Integration Flow as a Reactive Streams
Publisher bean. |
aggregate, aggregate, barrier, barrier, bridge, bridge, channel, channel, channel, channel, claimCheckIn, claimCheckIn, claimCheckOut, claimCheckOut, claimCheckOut, controlBus, controlBus, convert, convert, delay, delay, enrich, enrichHeaders, enrichHeaders, enrichHeaders, enrichHeaders, enrichHeaders, filter, filter, filter, filter, filter, filter, filter, filter, filter, filter, filter, fixedSubscriberChannel, fixedSubscriberChannel, fluxTransform, gateway, gateway, gateway, gateway, gateway, gateway, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, headerFilter, headerFilter, headerFilter, log, log, log, log, log, log, log, log, log, log, log, log, log, logAndReply, logAndReply, logAndReply, logAndReply, logAndReply, logAndReply, logAndReply, logAndReply, logAndReply, logAndReply, logAndReply, logAndReply, logAndReply, nullChannel, publishSubscribeChannel, publishSubscribeChannel, resequence, resequence, route, route, route, route, route, route, route, route, route, route, route, route, route, route, route, routeByException, routeToRecipients, scatterGather, scatterGather, scatterGather, scatterGather, scatterGather, scatterGather, split, split, split, split, split, split, split, split, split, split, split, split, split, split, split, split, split, split, transform, transform, transform, transform, transform, transform, transform, transform, transform, transform, transform, trigger, trigger, trigger, trigger, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap
_this, addComponent, addComponent, addComponents, checkReuse, currentComponent, currentMessageChannel, extractProxyTarget, getCurrentComponent, getCurrentMessageChannel, getIntegrationComponents, isImplicitChannel, isOutputChannelRequired, obtainInputChannelFromFlow, register, registerOutputChannelIfCan, route, setImplicitChannel
public StandardIntegrationFlow get()
get
in class BaseIntegrationFlowDefinition<IntegrationFlowBuilder>
public <T> org.reactivestreams.Publisher<Message<T>> toReactivePublisher()
BaseIntegrationFlowDefinition
Publisher
bean.toReactivePublisher
in class BaseIntegrationFlowDefinition<IntegrationFlowBuilder>
T
- the expected payload
typePublisher