IntegrationFlowAdapter (Spring Integration API)

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()

コンストラクター
コンストラクターと説明
`IntegrationFlowAdapter()`

メソッドのサマリー

すべてのメソッドインスタンスメソッド抽象メソッド具象メソッド
修飾子と型	メソッドと説明
`protected abstract IntegrationFlowDefinition<?>`	`buildFlow()`
`void`	`configure(IntegrationFlowDefinition<?> flow)` EIP メソッドのチェーンを宣言して、提供された `IntegrationFlowDefinition` との統合フローを構成するためのコールバックベースの関数。
`protected IntegrationFlowBuilder`	`from(ClassSE<?> serviceInterface)`
`protected IntegrationFlowBuilder`	`from(ClassSE<?> serviceInterface, java.util.function.ConsumerSE<GatewayProxySpec> endpointConfigurer)` サービスインターフェースのプロキシからフローを開始します。
`protected IntegrationFlowDefinition<?>`	`from(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.ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)`
`protected IntegrationFlowDefinition<?>`	`from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec)`
`protected IntegrationFlowDefinition<?>`	`from(MessageSourceSpec<?,? extends MessageSource<?>> messageSourceSpec, java.util.function.ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)`
`protected IntegrationFlowDefinition<?>`	`from(MessagingGatewaySpec<?,?> inboundGatewaySpec)`
`protected IntegrationFlowDefinition<?>`	`from(MessagingGatewaySupport inboundGateway)`
`protected IntegrationFlowBuilder`	`from(org.reactivestreams.Publisher<? extends Message<?>> publisher)`
`protected IntegrationFlowDefinition<?>`	`from(StringSE messageChannelName)`
`protected IntegrationFlowDefinition<?>`	`from(StringSE messageChannelName, boolean fixedSubscriber)`
`protected <T> IntegrationFlowBuilder`	`fromSupplier(java.util.function.SupplierSE<T> messageSource)`
`protected <T> IntegrationFlowBuilder`	`fromSupplier(java.util.function.SupplierSE<T> messageSource, java.util.function.ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)`
`MessageChannel`	`getInputChannel()` フロー入力チャネルに不可欠な最初の `MessageChannel` コンポーネントを返します。
`int`	`getPhase()`
`boolean`	`isAutoStartup()`
`boolean`	`isRunning()`
`void`	`start()`
`void`	`stop()`
`void`	`stop(RunnableSE callback)`

クラス java.lang.ObjectSE から継承されたメソッド
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE

コンストラクターの詳細
- IntegrationFlowAdapter
```
public IntegrationFlowAdapter()
```

メソッドの詳細

configure
```
public final void configure(IntegrationFlowDefinition<?> flow)
```
インターフェースからコピーされた説明: IntegrationFlow
EIP メソッドのチェーンを宣言して、提供された IntegrationFlowDefinition との統合フローを構成するためのコールバックベースの関数。
次で指定:
インターフェース IntegrationFlow の configure
パラメーター:
flow - 構成する IntegrationFlowDefinition

getInputChannel
```
public MessageChannel getInputChannel()
```
インターフェースからコピーされた説明: IntegrationFlow
フロー入力チャネルに不可欠な最初の MessageChannel コンポーネントを返します。
次で指定:
インターフェース IntegrationFlow の getInputChannel
戻り値:
チャンネル。

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,
                                            java.util.function.ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)

from

protected IntegrationFlowDefinition<?> from(MessageSource<?> messageSource,
                                            java.util.function.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(java.util.function.SupplierSE<T> messageSource)

fromSupplier

protected <T> IntegrationFlowBuilder fromSupplier(java.util.function.SupplierSE<T> messageSource,
                                                  java.util.function.ConsumerSE<SourcePollingChannelAdapterSpec> endpointConfigurer)

from

protected IntegrationFlowBuilder from(ClassSE<?> serviceInterface)

from
```
protected IntegrationFlowBuilder from(ClassSE<?> serviceInterface,
                                      @Nullable
                                      java.util.function.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

start

stop

stop

isRunning

isAutoStartup

getPhase

from

from

from

from

from

from

from

from

from

from

from

from

fromSupplier

fromSupplier

from

from

from

buildFlow