org.springframework.integration.dsl

Class IntegrationFlowAdapter

java.lang.Object

org.springframework.integration.dsl.IntegrationFlowAdapter

All Implemented Interfaces:

org.springframework.context.Lifecycle, org.springframework.context.Phased, org.springframework.context.SmartLifecycle, IntegrationFlow

public abstract class IntegrationFlowAdapter
extends java.lang.Object
implements IntegrationFlow, org.springframework.context.SmartLifecycle

The base Adapter class for the IntegrationFlow abstraction. Requires the implementation for the buildFlow() method to produce IntegrationFlowDefinition using one of from(java.lang.String) support methods.

Typically is used for target service implementation:

  @Component
  public class MyFlowAdapter extends IntegrationFlowAdapter {

     @Autowired
     private ConnectionFactory rabbitConnectionFactory;

     @Override
     protected IntegrationFlowDefinition<?> buildFlow() {
          return from(Amqp.inboundAdapter(this.rabbitConnectionFactory, "myQueue"))
                   .<String, String>transform(String::toLowerCase)
                   .channel(c -> c.queue("myFlowAdapterOutput"));
     }

 }
 

Since:

5.0

Author:

Artem Bilan

Constructor Summary

Constructors

Constructor and Description
IntegrationFlowAdapter()

Method Summary

Modifier and Type	Method and Description
protected abstract IntegrationFlowDefinition<?>	buildFlow()
void	configure(IntegrationFlowDefinition<?> flow) The callback-based function to declare the chain of EIP-methods to configure an integration flow with the provided IntegrationFlowDefinition.
protected IntegrationFlowDefinition<?>	from(org.springframework.messaging.MessageChannel messageChannel)
protected IntegrationFlowDefinition<?>	from(MessageChannelSpec<?,?> messageChannelSpec)
protected IntegrationFlowDefinition<?>	from(MessageProducerSpec<?,?> messageProducerSpec)
protected IntegrationFlowDefinition<?>	from(MessageProducerSupport messageProducer)
protected IntegrationFlowDefinition<?>	from(MessageSource<?> messageSource)
protected IntegrationFlowDefinition<?>	from(MessageSource<?> messageSource, java.util.function.Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
protected IntegrationFlowDefinition<?>	from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec)
protected IntegrationFlowDefinition<?>	from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec, java.util.function.Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
protected IntegrationFlowDefinition<?>	from(MessagingGatewaySpec<?,?> inboundGatewaySpec)
protected IntegrationFlowDefinition<?>	from(MessagingGatewaySupport inboundGateway)
protected IntegrationFlowBuilder	from(java.lang.Object service, java.lang.String methodName)
protected IntegrationFlowBuilder	from(java.lang.Object service, java.lang.String methodName, java.util.function.Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)
protected IntegrationFlowDefinition<?>	from(java.lang.String messageChannelName)
protected IntegrationFlowDefinition<?>	from(java.lang.String messageChannelName, boolean fixedSubscriber)
int	getPhase()
boolean	isAutoStartup()
boolean	isRunning()
void	start()
void	stop()
void	stop(java.lang.Runnable callback)

Methods inherited from class java.lang.Object

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

Constructor Detail

IntegrationFlowAdapter

public IntegrationFlowAdapter()

Method Detail

configure

public final void configure(IntegrationFlowDefinition<?> flow)

Description copied from interface: IntegrationFlow

The callback-based function to declare the chain of EIP-methods to configure an integration flow with the provided IntegrationFlowDefinition.

Specified by:

configure in interface IntegrationFlow

Parameters:

flow - the IntegrationFlowDefinition to configure

start

public void start()

Specified by:

start in interface org.springframework.context.Lifecycle

stop

public void stop(java.lang.Runnable callback)

Specified by:

stop in interface org.springframework.context.SmartLifecycle

stop

public void stop()

Specified by:

stop in interface org.springframework.context.Lifecycle

isRunning

public boolean isRunning()

Specified by:

isRunning in interface org.springframework.context.Lifecycle

isAutoStartup

public boolean isAutoStartup()

Specified by:

isAutoStartup in interface org.springframework.context.SmartLifecycle

getPhase

public int getPhase()

Specified by:

getPhase in interface org.springframework.context.Phased

from

protected IntegrationFlowDefinition<?> from(java.lang.String messageChannelName)

from

protected IntegrationFlowDefinition<?> from(org.springframework.messaging.MessageChannel messageChannel)

from

protected IntegrationFlowDefinition<?> from(java.lang.String messageChannelName,
                                            boolean fixedSubscriber)

from

protected IntegrationFlowDefinition<?> from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec,
                                            java.util.function.Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)

from

protected IntegrationFlowDefinition<?> from(MessageSource<?> messageSource,
                                            java.util.function.Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)

from

protected IntegrationFlowDefinition<?> from(MessageProducerSupport messageProducer)

from

protected IntegrationFlowDefinition<?> from(MessageSource<?> messageSource)

from

protected IntegrationFlowDefinition<?> from(MessagingGatewaySupport inboundGateway)

from

protected IntegrationFlowDefinition<?> from(MessageChannelSpec<?,?> messageChannelSpec)

from

protected IntegrationFlowDefinition<?> from(MessageProducerSpec<?,?> messageProducerSpec)

from

protected IntegrationFlowDefinition<?> from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec)

from

protected IntegrationFlowDefinition<?> from(MessagingGatewaySpec<?,?> inboundGatewaySpec)

from

protected IntegrationFlowBuilder from(java.lang.Object service,
                                      java.lang.String methodName)

from

protected IntegrationFlowBuilder from(java.lang.Object service,
                                      java.lang.String methodName,
                                      java.util.function.Consumer<SourcePollingChannelAdapterSpec> endpointConfigurer)

buildFlow

protected abstract IntegrationFlowDefinition<?> buildFlow()