public final class IntegrationFlows
extends java.lang.Object
IntegrationFlowBuilder
API.IntegrationFlowBeanPostProcessor
Modifier and Type | Class and Description |
---|---|
static interface |
IntegrationFlows.ChannelsFunction
|
static interface |
IntegrationFlows.MessageProducersFunction
The
MessageProducers -specific Function . |
static interface |
IntegrationFlows.MessageSourcesFunction
The
MessageSources -specific Function . |
static interface |
IntegrationFlows.MessagingGatewaysFunction
The
MessagingGateways -specific Function . |
Modifier and Type | Method and Description |
---|---|
static IntegrationFlowBuilder |
from(IntegrationFlows.ChannelsFunction channels)
Populate the
MessageChannel object to the
IntegrationFlowBuilder chain using the fluent API from Channels factory. |
static IntegrationFlowBuilder |
from(IntegrationFlows.MessageProducersFunction producers)
Populate the
MessageProducerSupport object to the IntegrationFlowBuilder chain
using the fluent API from the MessageProducers factory. |
static IntegrationFlowBuilder |
from(IntegrationFlows.MessageSourcesFunction sources)
Populate the
MessageSource object to the IntegrationFlowBuilder chain
using the fluent API from MessageSources factory. |
static IntegrationFlowBuilder |
from(IntegrationFlows.MessageSourcesFunction sources,
Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
Populate the
MessageSource object to the IntegrationFlowBuilder chain
using the fluent API from the MessageSources factory. |
static IntegrationFlowBuilder |
from(IntegrationFlows.MessagingGatewaysFunction gateways)
Populate the
MessagingGatewaySupport object to the IntegrationFlowBuilder chain
using the fluent API from the MessagingGateways factory. |
static IntegrationFlowBuilder |
from(org.springframework.messaging.MessageChannel messageChannel)
Populate the provided
MessageChannel object to the IntegrationFlowBuilder chain. |
static IntegrationFlowBuilder |
from(MessageChannelSpec<?,?> messageChannelSpec)
Populate the
MessageChannel object to the
IntegrationFlowBuilder chain using the fluent API from MessageChannelSpec . |
static IntegrationFlowBuilder |
from(MessageProducerSpec<?,?> messageProducerSpec)
Populate the
MessageProducerSupport object to the IntegrationFlowBuilder chain
using the fluent API from the MessageProducerSpec . |
static IntegrationFlowBuilder |
from(org.springframework.integration.endpoint.MessageProducerSupport messageProducer)
Populate the provided
MessageProducerSupport object to the IntegrationFlowBuilder chain. |
static IntegrationFlowBuilder |
from(org.springframework.integration.core.MessageSource<?> messageSource)
Populate the provided
MessageSource object to the IntegrationFlowBuilder chain. |
static IntegrationFlowBuilder |
from(org.springframework.integration.core.MessageSource<?> messageSource,
Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
Populate the provided
MessageSource object to the IntegrationFlowBuilder chain. |
static IntegrationFlowBuilder |
from(MessageSourceSpec<?,? extends org.springframework.integration.core.MessageSource<?>> messageSourceSpec)
Populate the
MessageSource object to the IntegrationFlowBuilder chain
using the fluent API from the provided MessageSourceSpec . |
static IntegrationFlowBuilder |
from(MessageSourceSpec<?,? extends org.springframework.integration.core.MessageSource<?>> messageSourceSpec,
Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
Populate the
MessageSource object to the IntegrationFlowBuilder chain
using the fluent API from the provided MessageSourceSpec . |
static IntegrationFlowBuilder |
from(MessagingGatewaySpec<?,?> inboundGatewaySpec)
Populate the
MessagingGatewaySupport object to the IntegrationFlowBuilder chain
using the fluent API from the MessagingGatewaySpec . |
static IntegrationFlowBuilder |
from(org.springframework.integration.gateway.MessagingGatewaySupport inboundGateway)
Populate the provided
MessagingGatewaySupport object to the IntegrationFlowBuilder chain. |
static IntegrationFlowBuilder |
from(java.lang.Object service,
java.lang.String methodName)
Populate the provided
MethodInvokingMessageSource for the method of the provided service. |
static IntegrationFlowBuilder |
from(java.lang.Object service,
java.lang.String methodName,
Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
Populate the provided
MethodInvokingMessageSource for the method of the provided service. |
static IntegrationFlowBuilder |
from(java.lang.String messageChannelName)
Populate the
MessageChannel name to the new IntegrationFlowBuilder chain. |
static IntegrationFlowBuilder |
from(java.lang.String messageChannelName,
boolean fixedSubscriber)
Populate the
MessageChannel name to the new IntegrationFlowBuilder chain. |
public static IntegrationFlowBuilder from(java.lang.String messageChannelName)
MessageChannel
name to the new IntegrationFlowBuilder
chain.
The IntegrationFlow
inputChannel
.messageChannelName
- the name of existing MessageChannel
bean.
The new DirectChannel
bean will be created on context startup
if there is no bean with this name.IntegrationFlowBuilder
.public static IntegrationFlowBuilder from(java.lang.String messageChannelName, boolean fixedSubscriber)
MessageChannel
name to the new IntegrationFlowBuilder
chain.
Typically for the FixedSubscriberChannel
together
with fixedSubscriber = true
.
The IntegrationFlow
inputChannel
.messageChannelName
- the name for DirectChannel
or
FixedSubscriberChannel
to be created on context startup, not reference.
The MessageChannel
depends on the fixedSubscriber
boolean argument.fixedSubscriber
- the boolean flag to determine if result MessageChannel
should
be DirectChannel
, if false
or
FixedSubscriberChannel
, if true
.IntegrationFlowBuilder
.DirectChannel
,
FixedSubscriberChannel
public static IntegrationFlowBuilder from(IntegrationFlows.ChannelsFunction channels)
MessageChannel
object to the
IntegrationFlowBuilder
chain using the fluent API from Channels
factory.
The IntegrationFlow
inputChannel
.channels
- the IntegrationFlows.ChannelsFunction
to use method chain to configure
MessageChannel
via Channels
factory.IntegrationFlowBuilder
.Channels
public static IntegrationFlowBuilder from(MessageChannelSpec<?,?> messageChannelSpec)
MessageChannel
object to the
IntegrationFlowBuilder
chain using the fluent API from MessageChannelSpec
.
The IntegrationFlow
inputChannel
.messageChannelSpec
- the MessageChannelSpec to populate MessageChannel
instance.IntegrationFlowBuilder
.MessageChannels
public static IntegrationFlowBuilder from(org.springframework.messaging.MessageChannel messageChannel)
MessageChannel
object to the IntegrationFlowBuilder
chain.
The IntegrationFlow
inputChannel
.messageChannel
- the MessageChannel
to populate.IntegrationFlowBuilder
.public static IntegrationFlowBuilder from(IntegrationFlows.MessageSourcesFunction sources)
MessageSource
object to the IntegrationFlowBuilder
chain
using the fluent API from MessageSources
factory.
The IntegrationFlow
startMessageSource
.sources
- the IntegrationFlows.MessageSourcesFunction
to use.IntegrationFlowBuilder
.MessageSources
public static IntegrationFlowBuilder from(IntegrationFlows.MessageSourcesFunction sources, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
MessageSource
object to the IntegrationFlowBuilder
chain
using the fluent API from the MessageSources
factory.
The IntegrationFlow
startMessageSource
.
In addition use SourcePollingChannelAdapterSpec
to provide options for the underlying
SourcePollingChannelAdapter
endpoint.sources
- the IntegrationFlows.MessageSourcesFunction
to use.endpointConfigurer
- the Consumer
to provide more options for the
SourcePollingChannelAdapterFactoryBean
.IntegrationFlowBuilder
.MessageSources
,
SourcePollingChannelAdapterSpec
public static IntegrationFlowBuilder from(MessageSourceSpec<?,? extends org.springframework.integration.core.MessageSource<?>> messageSourceSpec)
MessageSource
object to the IntegrationFlowBuilder
chain
using the fluent API from the provided MessageSourceSpec
.
The IntegrationFlow
startMessageSource
.messageSourceSpec
- the MessageSourceSpec
to use.IntegrationFlowBuilder
.and its implementations.
public static IntegrationFlowBuilder from(MessageSourceSpec<?,? extends org.springframework.integration.core.MessageSource<?>> messageSourceSpec, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
MessageSource
object to the IntegrationFlowBuilder
chain
using the fluent API from the provided MessageSourceSpec
.
The IntegrationFlow
startMessageSource
.messageSourceSpec
- the MessageSourceSpec
to use.endpointConfigurer
- the Consumer
to provide more options for the
SourcePollingChannelAdapterFactoryBean
.IntegrationFlowBuilder
.MessageSourceSpec
,
SourcePollingChannelAdapterSpec
public static IntegrationFlowBuilder from(java.lang.Object service, java.lang.String methodName)
MethodInvokingMessageSource
for the method of the provided service.
The IntegrationFlow
startMessageSource
.service
- the service to use.methodName
- the method to invoke.IntegrationFlowBuilder
.MethodInvokingMessageSource
public static IntegrationFlowBuilder from(java.lang.Object service, java.lang.String methodName, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
MethodInvokingMessageSource
for the method of the provided service.
The IntegrationFlow
startMessageSource
.service
- the service to use.methodName
- the method to invoke.endpointConfigurer
- the Consumer
to provide more options for the
SourcePollingChannelAdapterFactoryBean
.IntegrationFlowBuilder
.MethodInvokingMessageSource
public static IntegrationFlowBuilder from(org.springframework.integration.core.MessageSource<?> messageSource)
MessageSource
object to the IntegrationFlowBuilder
chain.
The IntegrationFlow
startMessageSource
.messageSource
- the MessageSource
to populate.IntegrationFlowBuilder
.MessageSource
public static IntegrationFlowBuilder from(org.springframework.integration.core.MessageSource<?> messageSource, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
MessageSource
object to the IntegrationFlowBuilder
chain.
The IntegrationFlow
startMessageSource
.
In addition use SourcePollingChannelAdapterSpec
to provide options for the underlying
SourcePollingChannelAdapter
endpoint.messageSource
- the MessageSource
to populate.endpointConfigurer
- the Consumer
to provide more options for the
SourcePollingChannelAdapterFactoryBean
.IntegrationFlowBuilder
.MessageSource
,
SourcePollingChannelAdapterSpec
public static IntegrationFlowBuilder from(IntegrationFlows.MessageProducersFunction producers)
MessageProducerSupport
object to the IntegrationFlowBuilder
chain
using the fluent API from the MessageProducers
factory.
The IntegrationFlow
startMessageProducer
.producers
- the IntegrationFlows.MessageProducersFunction
to use.IntegrationFlowBuilder
.MessageProducers
public static IntegrationFlowBuilder from(MessageProducerSpec<?,?> messageProducerSpec)
MessageProducerSupport
object to the IntegrationFlowBuilder
chain
using the fluent API from the MessageProducerSpec
.
The IntegrationFlow
startMessageProducer
.messageProducerSpec
- the MessageProducerSpec
to use.IntegrationFlowBuilder
.MessageProducerSpec
public static IntegrationFlowBuilder from(org.springframework.integration.endpoint.MessageProducerSupport messageProducer)
MessageProducerSupport
object to the IntegrationFlowBuilder
chain.
The IntegrationFlow
startMessageProducer
.messageProducer
- the MessageProducerSupport
to populate.IntegrationFlowBuilder
.public static IntegrationFlowBuilder from(IntegrationFlows.MessagingGatewaysFunction gateways)
MessagingGatewaySupport
object to the IntegrationFlowBuilder
chain
using the fluent API from the MessagingGateways
factory.
The IntegrationFlow
startMessagingGateway
.gateways
- the IntegrationFlows.MessagingGatewaysFunction
to use.IntegrationFlowBuilder
.MessagingGateways
public static IntegrationFlowBuilder from(MessagingGatewaySpec<?,?> inboundGatewaySpec)
MessagingGatewaySupport
object to the IntegrationFlowBuilder
chain
using the fluent API from the MessagingGatewaySpec
.
The IntegrationFlow
startMessagingGateway
.inboundGatewaySpec
- the IntegrationFlows.MessagingGatewaysFunction
to use.IntegrationFlowBuilder
.public static IntegrationFlowBuilder from(org.springframework.integration.gateway.MessagingGatewaySupport inboundGateway)
MessagingGatewaySupport
object to the IntegrationFlowBuilder
chain.
The IntegrationFlow
startMessageProducer
.inboundGateway
- the MessagingGatewaySupport
to populate.IntegrationFlowBuilder
.