ReactiveRedisStreamMessageProducer (Spring Integration API)

java.lang.ObjectSE
- org.springframework.integration.context.IntegrationObjectSupport
- - org.springframework.integration.endpoint.AbstractEndpoint
  - - org.springframework.integration.endpoint.MessageProducerSupport
    - - org.springframework.integration.redis.inbound.ReactiveRedisStreamMessageProducer

実装されたすべてのインターフェース:
Aware, BeanFactoryAware, BeanNameAware, DisposableBean, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Lifecycle, Phased, SmartLifecycle, ExpressionCapable, MessageProducer, IntegrationPattern, NamedComponent, ManageableLifecycle, ManageableSmartLifecycle, TrackableComponent
```
public class ReactiveRedisStreamMessageProducer
extends MessageProducerSupport
```
Redis ストリームからメッセージを読み取り、提供された出力チャネルに公開するための MessageProducerSupport。デフォルトでは、このアダプターはメッセージをスタンドアロンクライアント XREAD （Redis コマンド）として読み取りますが、consumerName フィールドを設定することにより、コンシューマーグループ機能 XREADGROUP に切り替えることができます。デフォルトでは、コンシューマーグループ名はこの Bean IntegrationObjectSupport.getBeanName() の ID です。
導入:
5.4
作成者:
Attoumane Ahamadi, Artem Bilan, Rohan Mukesh

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

コンストラクターの概要
コンストラクター
コンストラクターと説明
ReactiveRedisStreamMessageProducer(ReactiveRedisConnectionFactory reactiveConnectionFactory, StringSE streamKey)

コンストラクター
コンストラクターと説明
`ReactiveRedisStreamMessageProducer(ReactiveRedisConnectionFactory reactiveConnectionFactory, StringSE streamKey)`

メソッドのサマリー

すべてのメソッドインスタンスメソッド具象メソッド
修飾子と型	メソッドと説明
`protected void`	`doStart()` デフォルトでは何もしません。
`StringSE`	`getComponentType()` サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
`protected void`	`onInit()` サブクラスは、初期化ロジック用にこれを実装できます。
`void`	`setAutoAck(boolean autoAck)` コンシューマーグループで読み取ったメッセージを確認するかどうかを設定します。
`void`	`setConsumerGroup(StringSE consumerGroup)` コンシューマーグループの名前を設定します。
`void`	`setConsumerName(StringSE consumerName)` コンシューマーの名前を設定します。
`void`	`setCreateConsumerGroup(boolean createConsumerGroup)` コンシューマーグループが存在しない場合にのみ、コンシューマーグループを作成します。
`void`	`setExtractPayload(boolean extractPayload)` このチャネルアダプターを構成して、`Record` から値を抽出するかどうかを指定します。
`void`	`setReadOffset(ReadOffset readOffset)` メッセージを読み取るオフセットを定義します。
`void`	`setStreamReceiverOptions(StreamReceiver.StreamReceiverOptions<StringSE,?> streamReceiverOptions)` `StreamReceiver` のカスタマイズに使用する `ReactiveStreamOperations` を設定します。

クラス org.springframework.integration.endpoint.MessageProducerSupport から継承されたメソッド
afterSingletonsInstantiated, buildErrorMessage, doStop, getErrorChannel, getErrorMessageAttributes, getIntegrationPatternType, getMessagingTemplate, getOutputChannel, sendErrorMessageIfNecessary, sendMessage, setErrorChannel, setErrorChannelName, setErrorMessageStrategy, setOutputChannel, setOutputChannelName, setSendTimeout, setShouldTrack, subscribeToPublisher

クラス 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, 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

- コンストラクターの詳細
  - ReactiveRedisStreamMessageProducer
```
public ReactiveRedisStreamMessageProducer(ReactiveRedisConnectionFactory reactiveConnectionFactory,
                                          StringSE streamKey)
```
- メソッドの詳細
  - setReadOffset
```
public void setReadOffset(ReadOffset readOffset)
```
    メッセージを読み取るオフセットを定義します。デフォルトでは、ReadOffset.latest() が使用されます。ReadOffset.latest() は、ストリームに追加された新しいデータを取得するために XREAD で使用される ID である "$" と同じです。コンシューマーグループ機能に切り替えるときに、それが ReadOffset.latest() と等しい場合は、ReadOffset.lastConsumed() に設定することに注意してください。
    パラメーター:
    readOffset - 希望のオフセット
  - setExtractPayload
```
public void setExtractPayload(boolean extractPayload)
```
    このチャネルアダプターを構成して、Record から値を抽出するかどうかを指定します。
    パラメーター:
    extractPayload - デフォルト true
  - setAutoAck
```
public void setAutoAck(boolean autoAck)
```
    コンシューマーグループで読み取ったメッセージを確認するかどうかを設定します。デフォルトでは true。
    パラメーター:
    autoAck - 確認オプション。
  - setConsumerGroup
```
public void setConsumerGroup(@Nullable
                             StringSE consumerGroup)
```
    コンシューマーグループの名前を設定します。必要に応じて、そのコンシューマーグループを作成することができます。createConsumerGroup を参照してください。設定されていない場合、定義された Bean 名 IntegrationObjectSupport.getBeanName() が使用されます。
    パラメーター:
    consumerGroup - このアダプターがメッセージをリッスンするために登録する必要があるコンシューマーグループ。
  - setConsumerName
```
public void setConsumerName(@Nullable
                            StringSE consumerName)
```
    コンシューマーの名前を設定します。コンシューマー名が指定されると、このアダプターはコンシューマーグループ機能に切り替えられます。この値はグループ内で一意である必要があることに注意してください。
    パラメーター:
    consumerName - コンシューマーグループのコンシューマー名
  - setCreateConsumerGroup
```
public void setCreateConsumerGroup(boolean createConsumerGroup)
```
    コンシューマーグループが存在しない場合にのみ、コンシューマーグループを作成します。作成中に、ストリームも作成します。MKSTREAM を参照してください。
    パラメーター:
    createConsumerGroup - コンシューマーグループ、デフォルトで false を作成する必要があるかどうかを指定します
  - setStreamReceiverOptions
```
public void setStreamReceiverOptions(@Nullable
                                     StreamReceiver.StreamReceiverOptions<StringSE,?> streamReceiverOptions)
```
    StreamReceiver のカスタマイズに使用する ReactiveStreamOperations を設定します。ポーリングタイムアウトと直列化コンテキストを設定する方法を提供します。デフォルトでは、ポーリングタイムアウトは無限に設定され、StringRedisSerializer が使用されます。
    パラメーター:
    streamReceiverOptions - 必要なレシーバーオプション
  - getComponentType
```
public StringSE getComponentType()
```
    クラスからコピーされた説明: IntegrationObjectSupport
    サブクラスはこのメソッドを実装して、コンポーネント型情報を提供できます。
    次で指定:
    インターフェース NamedComponent の getComponentType
    オーバーライド:
    クラス IntegrationObjectSupport の getComponentType
  - onInit
```
protected void onInit()
```
    クラスからコピーされた説明: IntegrationObjectSupport
    サブクラスは、初期化ロジック用にこれを実装できます。
    オーバーライド:
    クラス MessageProducerSupport の onInit
  - doStart
```
protected void doStart()
```
    クラスからコピーされた説明: MessageProducerSupport
    デフォルトでは何も実行されません。ライフサイクル管理された動作が必要な場合、サブクラスはこれをオーバーライドできます。'lifecycleLock' によって保護されています。
    オーバーライド:
    クラス MessageProducerSupport の doStart

クラス ReactiveRedisStreamMessageProducer

フィールドのサマリー

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

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

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

コンストラクターの概要

メソッドのサマリー

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

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

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

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

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

コンストラクターの詳細

ReactiveRedisStreamMessageProducer

メソッドの詳細

setReadOffset

setExtractPayload

setAutoAck

setConsumerGroup

setConsumerName

setCreateConsumerGroup

setStreamReceiverOptions

getComponentType

onInit

doStart