クラス StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K, V はレコード <K, ?>> を継承します
java.lang.ObjectSE
org.springframework.data.redis.stream.StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K,V>
- 型パラメーター:
K
- ストリームキーとストリームフィールド型。V
- ストリーム値型。
- 含まれているインターフェース:
- StreamMessageListenerContainer < K , V はレコード < K , ?>> を継承します
public static class StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K,V extends Record<K,?>>
extends ObjectSE
StreamMessageListenerContainer
のオプション。メソッドの詳細
builder
getPollTimeout
読み取り中にBLOCK
オプションを使用してポーリングをブロックするためのタイムアウト。- 戻り値:
- タイムアウト。
getBatchSize
読み取り中にCOUNT
オプションを使用したバッチサイズのポーリング。- 戻り値:
- バッチサイズ。
getKeySerializer
getHashKeySerializer
getHashValueSerializer
getHashMapper
getRequiredHashMapper
hasHashMapper
public boolean hasHashMapper()getTargetType
getErrorHandler
- 戻り値:
- デフォルトの
ErrorHandler
。
getExecutor
- 戻り値:
Task
を実行するためのExecutor
SE。デフォルトはSimpleAsyncTaskExecutor
です。