Package org.springframework.integration.dsl

Class IntegrationFlowBuilder

java.lang.Object

org.springframework.integration.dsl.BaseIntegrationFlowDefinition<B>

org.springframework.integration.dsl.IntegrationFlowDefinition<IntegrationFlowBuilder>

org.springframework.integration.dsl.IntegrationFlowBuilder

public final class IntegrationFlowBuilder
extends IntegrationFlowDefinition<IntegrationFlowBuilder>

Since:

5.0

Author:

Artem Bilan

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

BaseIntegrationFlowDefinition.ReplyProducerCleaner

Field Summary

Fields inherited from class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

integrationComponents, PARSER

Method Summary

Modifier and Type	Method	Description
StandardIntegrationFlow	get()
<T> org.reactivestreams.Publisher<Message<T>>	toReactivePublisher()	Represent an Integration Flow as a Reactive Streams Publisher bean.
<T> org.reactivestreams.Publisher<Message<T>>	toReactivePublisher(boolean autoStartOnSubscribe)	Represent an Integration Flow as a Reactive Streams Publisher bean.

Methods inherited from class org.springframework.integration.dsl.IntegrationFlowDefinition

filter, filter, handle, handle, route, route, transform

Methods inherited from class org.springframework.integration.dsl.BaseIntegrationFlowDefinition

_this, addComponent, addComponent, addComponents, aggregate, aggregate, aggregate, barrier, barrier, bridge, bridge, channel, channel, channel, channel, checkReuse, claimCheckIn, claimCheckIn, claimCheckOut, claimCheckOut, claimCheckOut, controlBus, controlBus, controlBusOnRegistry, controlBusOnRegistry, convert, convert, currentComponent, currentInterceptableChannel, currentMessageChannel, delay, delay, enrich, enrichHeaders, enrichHeaders, enrichHeaders, enrichHeaders, enrichHeaders, extractProxyTarget, filter, filter, filter, filter, filter, filter, filter, filter, filter, fixedSubscriberChannel, fixedSubscriberChannel, fluxTransform, gateway, gateway, gateway, gateway, gateway, gateway, getCurrentComponent, getCurrentMessageChannel, getIntegrationComponents, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handle, handleReactive, handleReactive, handleReactive, handleReactive, headerFilter, headerFilter, headerFilter, intercept, isImplicitChannel, isOutputChannelRequired, log, log, log, log, log, log, log, log, log, log, log, log, log, nullChannel, obtainInputChannelFromFlow, publishSubscribeChannel, publishSubscribeChannel, publishSubscribeChannel, register, registerOutputChannelIfCan, resequence, resequence, route, route, route, route, route, route, route, route, route, route, route, route, route, route, routeByException, routeToRecipients, scatterGather, scatterGather, scatterGather, scatterGather, scatterGather, scatterGather, setImplicitChannel, split, split, split, split, split, split, split, split, split, splitWith, to, transform, transform, transform, transform, transform, transform, transformWith, trigger, trigger, trigger, trigger, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

get

public StandardIntegrationFlow get()

Overrides:

get in class BaseIntegrationFlowDefinition<IntegrationFlowBuilder>

toReactivePublisher

public <T>
org.reactivestreams.Publisher<Message<T>> toReactivePublisher()

Description copied from class: BaseIntegrationFlowDefinition

Represent an Integration Flow as a Reactive Streams Publisher bean.

Overrides:

toReactivePublisher in class BaseIntegrationFlowDefinition<IntegrationFlowBuilder>

Type Parameters:

T - the expected payload type

Returns:

the Reactive Streams Publisher

toReactivePublisher

public <T>
org.reactivestreams.Publisher<Message<T>> toReactivePublisher(boolean autoStartOnSubscribe)

Description copied from class: BaseIntegrationFlowDefinition

Represent an Integration Flow as a Reactive Streams Publisher bean.

Overrides:

toReactivePublisher in class BaseIntegrationFlowDefinition<IntegrationFlowBuilder>

Type Parameters:

T - the expected payload type

Parameters:

autoStartOnSubscribe - start message production and consumption in the flow, when a subscription to the publisher is initiated. If this set to true, the flow is marked to not start automatically by the application context.

Returns:

the Reactive Streams Publisher