java.lang.ObjectSE

org.springframework.integration.dsl.IntegrationFlowAdapter

実装されたすべてのインターフェース:: Lifecycle、Phased、SmartLifecycle、IntegrationFlow、ManageableLifecycle、ManageableSmartLifecycle

public abstract class IntegrationFlowAdapter extends ObjectSE implements IntegrationFlow, ManageableSmartLifecycle

IntegrationFlow 抽象化の基本 Adapter クラス。from(java.lang.String) サポートメソッドの 1 つを使用して IntegrationFlowDefinition を生成するには、buildFlow() メソッドの実装が必要です。

通常、ターゲットサービスの実装に使用されます。

  @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"));
     }

 }

導入:: 5.0
作成者:: Artem Bilan

フィールドサマリー
インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASE
コンストラクターのサマリー
コンストラクター
コンストラクター
説明
IntegrationFlowAdapter()
メソッドのサマリー
修飾子と型
メソッド
説明
protected abstract IntegrationFlowDefinition<?>
buildFlow()
final void
configure(IntegrationFlowDefinition<?> flow)
EIP メソッドのチェーンを宣言して、提供された IntegrationFlowDefinition との統合フローを構成するためのコールバックベースの関数。
protected IntegrationFlowBuilder
from(ClassSE<?> serviceInterface)
protected IntegrationFlowBuilder
from(ClassSE<?> serviceInterface, ConsumerSE<GatewayProxySpec> endpointConfigurer)
サービスインターフェースのプロキシからフローを開始します。
protected IntegrationFlowDefinition<?>
from(StringSE messageChannelName)
protected IntegrationFlowDefinition<?>
from(StringSE messageChannelName, boolean fixedSubscriber)
protected IntegrationFlowBuilder
from(org.reactivestreams.Publisher<? extends Message<?>> publisher)
protected IntegrationFlowDefinition<?>
from(MessageSource<?> messageSource)
protected IntegrationFlowDefinition<?>
from(MessageSource<?> messageSource, ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)
protected IntegrationFlowDefinition<?>
from(MessageChannelSpec<?,?> messageChannelSpec)
protected IntegrationFlowDefinition<?>
from(MessageProducerSpec<?,?> messageProducerSpec)
protected IntegrationFlowDefinition<?>
from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec)
protected IntegrationFlowDefinition<?>
from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec, ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)
protected IntegrationFlowDefinition<?>
from(MessagingGatewaySpec<?,?> inboundGatewaySpec)
protected IntegrationFlowDefinition<?>
from(MessageProducerSupport messageProducer)
protected IntegrationFlowDefinition<?>
from(MessagingGatewaySupport inboundGateway)
protected IntegrationFlowDefinition<?>
from(MessageChannel messageChannel)
protected <T> IntegrationFlowBuilder
fromSupplier(SupplierSE<T> messageSource)
protected <T> IntegrationFlowBuilder
fromSupplier(SupplierSE<T> messageSource, ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)
MessageChannel
getInputChannel()
基本的にフロー入力チャネルである最初の MessageChannel コンポーネントを返します。
MapSE<ObjectSE,StringSE>
getIntegrationComponents()
このフローによって管理される統合コンポーネントのマップを返します（存在する場合）。
int
getPhase()
boolean
isAutoStartup()
boolean
isRunning()
void
start()
void
stop()
void
stop(RunnableSE callback)
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

コンストラクターの詳細
- IntegrationFlowAdapter
  public IntegrationFlowAdapter()
メソッドの詳細
- configure
  public final void configure(IntegrationFlowDefinition<?> flow)
  インターフェースからコピーされた説明: IntegrationFlow
  EIP メソッドのチェーンを宣言して、提供された IntegrationFlowDefinition との統合フローを構成するためのコールバックベースの関数。
  次で指定:
  インターフェース IntegrationFlow の configure
  パラメーター:
  flow - 構成する IntegrationFlowDefinition
- getInputChannel
  @Nullable public MessageChannel getInputChannel()
  インターフェースからコピーされた説明: IntegrationFlow
  基本的にフロー入力チャネルである最初の MessageChannel コンポーネントを返します。
  次で指定:
  インターフェース IntegrationFlow の getInputChannel
  戻り値:
  チャンネル。
- getIntegrationComponents
  public MapSE<ObjectSE,StringSE> getIntegrationComponents()
  インターフェースからコピーされた説明: IntegrationFlow
  このフローによって管理される統合コンポーネントのマップを返します（存在する場合）。
  次で指定:
  インターフェース IntegrationFlow の getIntegrationComponents
  戻り値:
  このフローによって管理される統合コンポーネントのマップ。
- start
  public void start()
  次で指定:
  インターフェース Lifecycle の start
  次で指定:
  インターフェース ManageableLifecycle の start
- stop
  public void stop(RunnableSE callback)
  次で指定:
  インターフェース SmartLifecycle の stop
- stop
  public void stop()
  次で指定:
  インターフェース Lifecycle の stop
  次で指定:
  インターフェース ManageableLifecycle の stop
- isRunning
  public boolean isRunning()
  次で指定:
  インターフェース Lifecycle の isRunning
  次で指定:
  インターフェース ManageableLifecycle の isRunning
- isAutoStartup
  public boolean isAutoStartup()
  次で指定:
  インターフェース SmartLifecycle の isAutoStartup
- getPhase
  public int getPhase()
  次で指定:
  インターフェース Phased の getPhase
  次で指定:
  インターフェース SmartLifecycle の getPhase
- from
  protected IntegrationFlowDefinition<?> from(StringSE messageChannelName)
- from
  protected IntegrationFlowDefinition<?> from(MessageChannel messageChannel)
- from
  protected IntegrationFlowDefinition<?> from(StringSE messageChannelName, boolean fixedSubscriber)
- from
  protected IntegrationFlowDefinition<?> from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec, ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)
- from
  protected IntegrationFlowDefinition<?> from(MessageSource<?> messageSource, ConsumerSE<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)
- fromSupplier
  protected <T> IntegrationFlowBuilder fromSupplier(SupplierSE<T> messageSource)
- fromSupplier
  protected <T> IntegrationFlowBuilder fromSupplier(SupplierSE<T> messageSource, ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)
- from
  protected IntegrationFlowBuilder from(ClassSE<?> serviceInterface)
- from
  protected IntegrationFlowBuilder from(ClassSE<?> serviceInterface, @Nullable ConsumerSE<GatewayProxySpec> endpointConfigurer)
  サービスインターフェースのプロキシからフローを開始します。
  パラメーター:
  serviceInterface - サービスインターフェースクラス。
  endpointConfigurer - ゲートウェイのプロキシ Bean を構成するための ConsumerSE。
  戻り値:
  新しい IntegrationFlowBuilder。
  導入:
  5.2
- from
  protected IntegrationFlowBuilder from(org.reactivestreams.Publisher<? extends Message<?>> publisher)
- buildFlow
  protected abstract IntegrationFlowDefinition<?> buildFlow()

クラス IntegrationFlowAdapter

フィールドサマリー

インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド

コンストラクターのサマリー

メソッドのサマリー

クラス java.lang.ObjectSE から継承されたメソッド

コンストラクターの詳細

IntegrationFlowAdapter

メソッドの詳細

configure

getInputChannel

getIntegrationComponents

start

stop

stop

isRunning

isAutoStartup

getPhase

from

from

from

from

from

from

from

from

from

from

from

from

fromSupplier

fromSupplier

from

from

from

buildFlow