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

Method Summary

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.

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

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

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

_this, addComponent, addComponent, addComponents, currentComponent, currentMessageChannel, getCurrentComponent, getCurrentMessageChannel, getIntegrationComponents, isImplicitChannel, setImplicitChannel

Methods inherited from class java.lang.Object

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

Method Detail

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