ReactiveStreamsConsumer (Spring Integration API)

java.lang.ObjectSE
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.endpoint.AbstractEndpoint
  - - org.springframework.integration.endpoint.ReactiveStreamsConsumer

実装されたすべてのインターフェース:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ExpressionCapable, IntegrationConsumer, NamedComponent, ManageableLifecycle, ManageableSmartLifecycle
```
public class ReactiveStreamsConsumer
extends AbstractEndpoint
implements IntegrationConsumer
```
入力チャネルへの Reactive Streams サブスクリプションおよびそのチャネルからのメッセージのリアクティブな消費のための AbstractEndpoint 実装。
導入:
5.0
作成者:
Artem Bilan

フィールドのサマリー
- クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド
  lifecycleCondition, lifecycleLock
- クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
  EXPRESSION_PARSER, logger
- インターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
  DEFAULT_PHASE

コンストラクターの概要

コンストラクター
コンストラクターと説明
`ReactiveStreamsConsumer(MessageChannel inputChannel, MessageHandler messageHandler)`
`ReactiveStreamsConsumer(MessageChannel inputChannel, ReactiveMessageHandler reactiveMessageHandler)` 提供された `MessageChannel` および `ReactiveMessageHandler` に基づいてエンドポイントをインスタンス化します。
`ReactiveStreamsConsumer(MessageChannel inputChannel, org.reactivestreams.Subscriber<Message<?>> subscriber)`

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`protected void`	`doStart()` サブクラスは、開始動作でこのメソッドを実装する必要があります。
`protected void`	`doStop()` サブクラスは、停止動作でこのメソッドを実装する必要があります。
`MessageHandler`	`getHandler()` コンシューマーのハンドラーを返します。
`MessageChannel`	`getInputChannel()` 入力チャンネルを返します。
`MessageChannel`	`getOutputChannel()` 出力チャネルを返します（null の場合があります）。
`protected void`	`onInit()` サブクラスは、初期化ロジック用にこれを実装できます。
`void`	`setErrorHandler(ErrorHandler errorHandler)`

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド
destroy, doStop, getPhase, getRole, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stop

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentName, getComponentType, getConversionService, getExpression, getIntegrationProperties, getIntegrationProperty, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toString

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

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName, getComponentType

- コンストラクターの詳細
  - ReactiveStreamsConsumer
```
public ReactiveStreamsConsumer(MessageChannel inputChannel,
                               MessageHandler messageHandler)
```
  - ReactiveStreamsConsumer
```
public ReactiveStreamsConsumer(MessageChannel inputChannel,
                               org.reactivestreams.Subscriber<Message<?>> subscriber)
```
  - ReactiveStreamsConsumer
```
public ReactiveStreamsConsumer(MessageChannel inputChannel,
                               ReactiveMessageHandler reactiveMessageHandler)
```
    提供された MessageChannel および ReactiveMessageHandler に基づいてエンドポイントをインスタンス化します。
    パラメーター:
    inputChannel - リアクティブに消費するチャネル。
    reactiveMessageHandler - メッセージを処理するための ReactiveMessageHandler。
    導入:
    5.3
- メソッドの詳細
  - setErrorHandler
```
public void setErrorHandler(ErrorHandler errorHandler)
```
  - getInputChannel
```
public MessageChannel getInputChannel()
```
    インターフェースからコピーされた説明: IntegrationConsumer
    入力チャンネルを返します。
    次で指定:
    インターフェース IntegrationConsumer の getInputChannel
    戻り値:
    入力チャンネル。
  - getOutputChannel
```
public MessageChannel getOutputChannel()
```
    インターフェースからコピーされた説明: IntegrationConsumer
    出力チャネルを返します（null の場合があります）。
    次で指定:
    インターフェース IntegrationConsumer の getOutputChannel
    戻り値:
    出力チャンネル。
  - getHandler
```
public MessageHandler getHandler()
```
    インターフェースからコピーされた説明: IntegrationConsumer
    コンシューマーのハンドラーを返します。
    次で指定:
    インターフェース IntegrationConsumer の getHandler
    戻り値:
    ハンドラー。
  - onInit
```
protected void onInit()
```
    クラスからコピーされた説明: IntegrationObjectSupport
    サブクラスは、初期化ロジック用にこれを実装できます。
    オーバーライド:
    クラス AbstractEndpoint の onInit
  - doStart
```
protected void doStart()
```
    クラスからコピーされた説明: AbstractEndpoint
    サブクラスは、開始動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。
    次で指定:
    クラス AbstractEndpoint の doStart
  - doStop
```
protected void doStop()
```
    クラスからコピーされた説明: AbstractEndpoint
    サブクラスは、停止動作でこのメソッドを実装する必要があります。このメソッドは、AbstractEndpoint.lifecycleLock を保持しているときに呼び出されます。
    次で指定:
    クラス AbstractEndpoint の doStop

クラス ReactiveStreamsConsumer

フィールドのサマリー

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド

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

コンストラクターの概要

メソッドのサマリー

クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド

クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド

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

インターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド

コンストラクターの詳細

ReactiveStreamsConsumer

ReactiveStreamsConsumer

ReactiveStreamsConsumer

メソッドの詳細

setErrorHandler

getInputChannel

getOutputChannel

getHandler

onInit

doStart

doStop