クラス ReactiveRedisStreamMessageHandler
java.lang.ObjectSE
org.springframework.integration.context.IntegrationObjectSupport
org.springframework.integration.handler.MessageHandlerSupport
org.springframework.integration.handler.AbstractReactiveMessageHandler
org.springframework.integration.redis.outbound.ReactiveRedisStreamMessageHandler
- 実装されているすべてのインターフェース:
Aware、BeanFactoryAware、BeanNameAware、DisposableBean、InitializingBean、ApplicationContextAware、Ordered、ComponentSourceAware、ExpressionCapable、Orderable、IntegrationPattern、NamedComponent、IntegrationManagement、TrackableComponent、ReactiveMessageHandler
リアクティブストリーム操作を使用して、メッセージペイロードまたはメッセージ自体（
extractPayload を参照）を Redis ストリームに書き込む ReactiveMessageHandler の実装。- 導入:
- 5.4
- 作成者:
- Attoumane Ahamadi, Artem Bilan
ネストされたクラスの要約
インターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたネストクラス / インターフェース
IntegrationManagement.ManagementOverridesフィールドのサマリー
クラス org.springframework.integration.context.IntegrationObjectSupport から継承されたフィールド
EXPRESSION_PARSER, loggerインターフェース org.springframework.integration.support.management.IntegrationManagement から継承されたフィールド
METER_PREFIX, RECEIVE_COUNTER_NAME, SEND_TIMER_NAMEインターフェース org.springframework.core.Ordered から継承されたフィールド
HIGHEST_PRECEDENCE, LOWEST_PRECEDENCEコンストラクターの概要
コンストラクターコンストラクター説明ReactiveRedisStreamMessageHandler(ReactiveRedisConnectionFactory connectionFactory, StringSE streamKey) 提供されたReactiveRedisConnectionFactoryとストリームのキーに基づいてインスタンスを作成します。ReactiveRedisStreamMessageHandler(ReactiveRedisConnectionFactory connectionFactory, Expression streamKeyExpression) 提供されたReactiveRedisConnectionFactoryとストリームキーの式に基づいてインスタンスを作成します。メソッドのサマリー
修飾子と型メソッド説明protected reactor.core.publisher.Mono<VoidSE> handleMessageInternal(Message<?> message) protected voidonInit()サブクラスは、初期化ロジック用にこれを実装できます。voidsetAddOptionsFunction(FunctionSE<Message<?>, RedisStreamCommands.XAddOptions> addOptionsFunction) リクエストメッセージに基づいてRedisStreamCommands.XAddOptionsを作成する関数を設定します。voidsetExtractPayload(boolean extractPayload) ペイロードを抽出するには、trueに設定します。それ以外の場合は、メッセージ全体が送信されます。voidsetHashMapper(@Nullable HashMapper<StringSE, ?, ?> hashMapper) （オプション）reactiveStreamOperationsの作成に使用するHashMapperを設定します。voidsetSerializationContext(RedisSerializationContext<StringSE, ?> serializationContext) クラス org.springframework.integration.handler.AbstractReactiveMessageHandler から継承されたメソッド
handleMessageクラス org.springframework.integration.handler.MessageHandlerSupport から継承されたメソッド
buildSendTimer, destroy, getIntegrationPatternType, getManagedName, getManagedType, getMetricsCaptor, getObservationRegistry, getOrder, getOverrides, isLoggingEnabled, isObserved, registerMetricsCaptor, registerObservationRegistry, sendTimer, setLoggingEnabled, setManagedName, setManagedType, setOrder, setShouldTrack, shouldTrackクラス org.springframework.integration.context.IntegrationObjectSupport から継承されたメソッド
afterPropertiesSet, extractTypeIfPossible, generateId, getApplicationContext, getApplicationContextId, getBeanDescription, getBeanFactory, getBeanName, getChannelResolver, getComponentDescription, getComponentName, getComponentSource, 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.management.IntegrationManagement から継承されたメソッド
getThisAsインターフェース org.springframework.integration.support.context.NamedComponent から継承されたメソッド
getBeanName, getComponentName
コンストラクターの詳細
ReactiveRedisStreamMessageHandler
public ReactiveRedisStreamMessageHandler(ReactiveRedisConnectionFactory connectionFactory, StringSE streamKey) 提供されたReactiveRedisConnectionFactoryとストリームのキーに基づいてインスタンスを作成します。- パラメーター:
connectionFactory- 使用するReactiveRedisConnectionFactorystreamKey- ストリームのキー
ReactiveRedisStreamMessageHandler
public ReactiveRedisStreamMessageHandler(ReactiveRedisConnectionFactory connectionFactory, Expression streamKeyExpression) 提供されたReactiveRedisConnectionFactoryとストリームキーの式に基づいてインスタンスを作成します。- パラメーター:
connectionFactory- 使用するReactiveRedisConnectionFactorystreamKeyExpression- ストリームのキーを評価するための SpEL 式
メソッドの詳細
setSerializationContext
setHashMapper
（オプション）reactiveStreamOperationsの作成に使用するHashMapperを設定します。デフォルトのHashMapperは、提供されているRedisSerializationContextから定義されます。- パラメーター:
hashMapper- 求められている hashMapper
setExtractPayload
public void setExtractPayload(boolean extractPayload) ペイロードを抽出するには、trueに設定します。それ以外の場合は、メッセージ全体が送信されます。デフォルトのtrue。- パラメーター:
extractPayload- 抽出しない場合は false。
setAddOptionsFunction
public void setAddOptionsFunction(FunctionSE<Message<?>, RedisStreamCommands.XAddOptions> addOptionsFunction) リクエストメッセージに基づいてRedisStreamCommands.XAddOptionsを作成する関数を設定します。null にすることはできず、null を返すこともできません。- パラメーター:
addOptionsFunction-RedisStreamCommands.XAddOptionsを提供する機能。- 導入:
- 6.5
getComponentType
- 次で指定:
- インターフェース
NamedComponentのgetComponentType - オーバーライド:
- クラス
MessageHandlerSupportのgetComponentType
onInit
protected void onInit()クラスからコピーされた説明:IntegrationObjectSupportサブクラスは、初期化ロジック用にこれを実装できます。- オーバーライド:
- クラス
IntegrationObjectSupportのonInit
handleMessageInternal
- 次で指定:
- クラス
AbstractReactiveMessageHandlerのhandleMessageInternal