クラス 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
、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 void
onInit()
サブクラスは、初期化ロジック用にこれを実装できます。void
setExtractPayload
(boolean extractPayload) ペイロードを抽出するには、true
に設定します。それ以外の場合は、メッセージ全体が送信されます。void
setHashMapper
(HashMapper<StringSE, ?, ?> hashMapper) (オプション)reactiveStreamOperations
の作成に使用するHashMapper
を設定します。void
setSerializationContext
(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, getComponentName, getConversionService, getExpression, getIntegrationProperties, getMessageBuilderFactory, getTaskScheduler, isInitialized, setApplicationContext, setBeanFactory, setBeanName, setChannelResolver, setComponentName, 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
- 使用するReactiveRedisConnectionFactory
streamKey
- ストリームのキー
ReactiveRedisStreamMessageHandler
public ReactiveRedisStreamMessageHandler(ReactiveRedisConnectionFactory connectionFactory, Expression streamKeyExpression) 提供されたReactiveRedisConnectionFactory
とストリームキーの式に基づいてインスタンスを作成します。- パラメーター:
connectionFactory
- 使用するReactiveRedisConnectionFactory
streamKeyExpression
- ストリームのキーを評価するための SpEL 式
メソッドの詳細
setSerializationContext
setHashMapper
(オプション)reactiveStreamOperations
の作成に使用するHashMapper
を設定します。デフォルトのHashMapper
は、提供されているRedisSerializationContext
から定義されます。- パラメーター:
hashMapper
- 求められている hashMapper
setExtractPayload
public void setExtractPayload(boolean extractPayload) ペイロードを抽出するには、true
に設定します。それ以外の場合は、メッセージ全体が送信されます。デフォルトのtrue
。- パラメーター:
extractPayload
- 抽出しない場合は false。
getComponentType
クラスからコピーされた説明:IntegrationObjectSupport
サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。- 次で指定:
- インターフェース
NamedComponent
のgetComponentType
- オーバーライド:
- クラス
MessageHandlerSupport
のgetComponentType
onInit
protected void onInit()クラスからコピーされた説明:IntegrationObjectSupport
サブクラスは、初期化ロジック用にこれを実装できます。- オーバーライド:
- クラス
IntegrationObjectSupport
のonInit
handleMessageInternal
- 次で指定:
- クラス
AbstractReactiveMessageHandler
のhandleMessageInternal