クラス ReactiveStreamsConsumer
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、ComponentSourceAware、ExpressionCapable、IntegrationConsumer、NamedComponent、ManageableLifecycle、ManageableSmartLifecycle
入力チャネルへの Reactive Streams サブスクリプションおよびそのチャネルからのメッセージのリアクティブな消費のための
AbstractEndpoint 実装。- 導入:
- 5.0
- 作成者:
- Artem Bilan, Trung Pham
フィールドのサマリー
クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたフィールド
lifecycleCondition, lifecycleLockクラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, loggerインターフェース org.springframework.context.SmartLifecycle から継承されたフィールド
DEFAULT_PHASEコンストラクターの概要
コンストラクターコンストラクター説明ReactiveStreamsConsumer(MessageChannel inputChannel, org.reactivestreams.Subscriber<Message<?>> subscriber) ReactiveStreamsConsumer(MessageChannel inputChannel, MessageHandler messageHandler) ReactiveStreamsConsumer(MessageChannel inputChannel, ReactiveMessageHandler reactiveMessageHandler) 提供されたMessageChannelおよびReactiveMessageHandlerに基づいてエンドポイントをインスタンス化します。メソッドのサマリー
修飾子と型メソッド説明protected voiddoStart()サブクラスは、開始動作でこのメソッドを実装する必要があります。protected voiddoStop()サブクラスは、停止動作でこのメソッドを実装する必要があります。コンシューマーのハンドラーを返します。入力チャンネルを返します。出力チャネルを返します（null の場合があります）。protected voidonInit()サブクラスは、初期化ロジック用にこれを実装できます。voidsetErrorHandler(ErrorHandler errorHandler) voidsetReactiveCustomizer(FunctionSE<? super reactor.core.publisher.Flux<Message<?>>, ? extends org.reactivestreams.Publisher<Message<?>>> reactiveCustomizer) クラス org.springframework.integration.endpoint.AbstractEndpoint から継承されたメソッド
destroy, doStop, getPhase, getRole, isActive, isAutoStartup, isRunning, setAutoStartup, setPhase, setRole, start, stop, stopクラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, getComponentType, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentDescription, setComponentName, setComponentSource, setConversionService, setMessageBuilderFactory, setPrimaryExpression, setTaskScheduler, toStringクラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, wait, waitSE, waitSEインターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName, getComponentType
コンストラクターの詳細
ReactiveStreamsConsumer
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
setReactiveCustomizer
public void setReactiveCustomizer(@Nullable FunctionSE<? super reactor.core.publisher.Flux<Message<?>>, ? extends org.reactivestreams.Publisher<Message<?>>> reactiveCustomizer) getInputChannel
インターフェースからコピーされた説明:IntegrationConsumer入力チャンネルを返します。- 次で指定:
- インターフェース
IntegrationConsumerのgetInputChannel - 戻り値:
- 入力チャンネル。
getOutputChannel
インターフェースからコピーされた説明:IntegrationConsumer出力チャネルを返します（null の場合があります）。- 次で指定:
- インターフェース
IntegrationConsumerのgetOutputChannel - 戻り値:
- 出力チャンネル。
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