public final class IntegrationFlows
extends java.lang.Object
IntegrationFlowBuilder
API.Modifier and Type | Class and Description |
---|---|
static interface |
IntegrationFlows.ChannelsFunction |
static interface |
IntegrationFlows.MessageProducersFunction |
static interface |
IntegrationFlows.MessageSourcesFunction |
static interface |
IntegrationFlows.MessagingGatewaysFunction |
Modifier and Type | Method and Description |
---|---|
static IntegrationFlowBuilder |
from(IntegrationFlows.ChannelsFunction channels) |
static IntegrationFlowBuilder |
from(IntegrationFlows.MessageProducersFunction producers) |
static IntegrationFlowBuilder |
from(IntegrationFlows.MessageSourcesFunction sources) |
static IntegrationFlowBuilder |
from(IntegrationFlows.MessageSourcesFunction sources,
Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer) |
static IntegrationFlowBuilder |
from(IntegrationFlows.MessagingGatewaysFunction gateways) |
static IntegrationFlowBuilder |
from(org.springframework.messaging.MessageChannel messageChannel) |
static IntegrationFlowBuilder |
from(MessageChannelSpec<?,?> messageChannelSpec) |
static IntegrationFlowBuilder |
from(MessageProducerSpec<?,?> messageProducerSpec) |
static IntegrationFlowBuilder |
from(org.springframework.integration.endpoint.MessageProducerSupport messageProducer) |
static IntegrationFlowBuilder |
from(org.springframework.integration.core.MessageSource<?> messageSource) |
static IntegrationFlowBuilder |
from(org.springframework.integration.core.MessageSource<?> messageSource,
Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer) |
static IntegrationFlowBuilder |
from(MessageSourceSpec<?,? extends org.springframework.integration.core.MessageSource<?>> messageSourceSpec) |
static IntegrationFlowBuilder |
from(MessageSourceSpec<?,? extends org.springframework.integration.core.MessageSource<?>> messageSourceSpec,
Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer) |
static IntegrationFlowBuilder |
from(MessagingGatewaySpec<?,?> inboundGatewaySpec) |
static IntegrationFlowBuilder |
from(org.springframework.integration.gateway.MessagingGatewaySupport inboundGateway) |
static IntegrationFlowBuilder |
from(java.lang.String messageChannelName) |
static IntegrationFlowBuilder |
from(java.lang.String messageChannelName,
boolean fixedSubscriber) |
public static IntegrationFlowBuilder from(java.lang.String messageChannelName)
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)
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
public static IntegrationFlowBuilder from(IntegrationFlows.ChannelsFunction channels)
public static IntegrationFlowBuilder from(MessageChannelSpec<?,?> messageChannelSpec)
public static IntegrationFlowBuilder from(org.springframework.messaging.MessageChannel messageChannel)
public static IntegrationFlowBuilder from(IntegrationFlows.MessageSourcesFunction sources)
public static IntegrationFlowBuilder from(IntegrationFlows.MessageSourcesFunction sources, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
public static IntegrationFlowBuilder from(MessageSourceSpec<?,? extends org.springframework.integration.core.MessageSource<?>> messageSourceSpec)
public static IntegrationFlowBuilder from(MessageSourceSpec<?,? extends org.springframework.integration.core.MessageSource<?>> messageSourceSpec, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
public static IntegrationFlowBuilder from(org.springframework.integration.core.MessageSource<?> messageSource)
public static IntegrationFlowBuilder from(org.springframework.integration.core.MessageSource<?> messageSource, Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
public static IntegrationFlowBuilder from(IntegrationFlows.MessageProducersFunction producers)
public static IntegrationFlowBuilder from(MessageProducerSpec<?,?> messageProducerSpec)
public static IntegrationFlowBuilder from(org.springframework.integration.endpoint.MessageProducerSupport messageProducer)
public static IntegrationFlowBuilder from(IntegrationFlows.MessagingGatewaysFunction gateways)
public static IntegrationFlowBuilder from(MessagingGatewaySpec<?,?> inboundGatewaySpec)
public static IntegrationFlowBuilder from(org.springframework.integration.gateway.MessagingGatewaySupport inboundGateway)