クラス StreamReceiver.StreamReceiverOptionsBuilder<K, V はレコード <K, ?>> を継承します
java.lang.ObjectSE
org.springframework.data.redis.stream.StreamReceiver.StreamReceiverOptionsBuilder<K,V>
- 型パラメーター:
K
- ストリームキーとストリームフィールド型。
- 含まれているインターフェース:
- StreamReceiver < K , V はレコード < K , ?>> を継承します
メソッドのサマリー
修飾子と型メソッド説明batchSize
(int recordsPerPoll) 読み取り中にCOUNT
オプションのバッチサイズを構成します。build()
新しいStreamReceiver.StreamReceiverOptions
を構築します。<HK,
HV> StreamReceiver.StreamReceiverOptionsBuilder<K, MapRecord<K, HK, HV>> ハッシュキーシリアライザーを構成します。<HK,
HV> StreamReceiver.StreamReceiverOptionsBuilder<K, MapRecord<K, HK, HV>> ハッシュ値シリアライザーを構成します。<NK,
NV extends Record<NK, ?>>
StreamReceiver.StreamReceiverOptionsBuilder<NK,NV> キーシリアライザーを構成します。objectMapper
(HashMapper<NV, ?, ?> hashMapper) ハッシュマッパーを構成します。onErrorResume
(FunctionSE<? super ThrowableSE, ? extends org.reactivestreams.Publisher<VoidSE>> resumeFunction) ストリームのポーリングが失敗したときにメインシーケンスを再開するように再開Function
SE を構成します。pollTimeout
(DurationSE pollTimeout) 読み取り中にBLOCK
オプションのポーリングタイムアウトを設定します。<T> StreamReceiver.StreamReceiverOptionsBuilder<T,
MapRecord<T, T, T>> キー、ハッシュキー、ハッシュ値シリアライザーを構成します。<T> StreamReceiver.StreamReceiverOptionsBuilder<T,
MapRecord<T, T, T>> serializer
(RedisSerializationContext<T, ?> serializationContext) キー、ハッシュキー、ハッシュ値シリアライザーを構成します。targetType
(ClassSE<NV> targetType) ハッシュターゲット型を構成します。
メソッドの詳細
pollTimeout
読み取り中にBLOCK
オプションのポーリングタイムアウトを設定します。- パラメーター:
pollTimeout
- null または負であってはなりません。- 戻り値:
this
StreamReceiver.StreamReceiverOptionsBuilder
。
batchSize
読み取り中にCOUNT
オプションのバッチサイズを構成します。- パラメーター:
recordsPerPoll
- ゼロより大きくなければなりません。- 戻り値:
this
StreamReceiver.StreamReceiverOptionsBuilder
。
onErrorResume
public StreamReceiver.StreamReceiverOptionsBuilder<K,V> onErrorResume(FunctionSE<? super ThrowableSE, ? extends org.reactivestreams.Publisher<VoidSE>> resumeFunction) ストリームのポーリングが失敗したときにメインシーケンスを再開するように再開Function
SE を構成します。この関数は、エラーを抑制して再開するか、エラーを発行して受信を停止することでメインシーケンスを失敗させることができます。受信エラー (Redis エラー、直列化エラー) は、デフォルトで受信を停止します。- パラメーター:
resumeFunction
- null であってはなりません。- 戻り値:
this
StreamReceiver.StreamReceiverOptionsBuilder
。- 導入:
- 2.x
- 関連事項:
Flux.onErrorResume(Function)
serializer
public <T> StreamReceiver.StreamReceiverOptionsBuilder<T,MapRecord<T, serializerT, T>> (RedisSerializationContext.SerializationPair<T> pair) キー、ハッシュキー、ハッシュ値シリアライザーを構成します。- パラメーター:
pair
- null であってはなりません。- 戻り値:
this
StreamReceiver.StreamReceiverOptionsBuilder
。
serializer
public <T> StreamReceiver.StreamReceiverOptionsBuilder<T,MapRecord<T, serializerT, T>> (RedisSerializationContext<T, ?> serializationContext) キー、ハッシュキー、ハッシュ値シリアライザーを構成します。- パラメーター:
serializationContext
- null であってはなりません。- 戻り値:
this
StreamReceiver.StreamReceiverOptionsBuilder
。
keySerializer
public <NK,NV extends Record<NK, StreamReceiver.StreamReceiverOptionsBuilder<NK,?>> NV> keySerializer(RedisSerializationContext.SerializationPair<NK> pair) キーシリアライザーを構成します。- パラメーター:
pair
- null であってはなりません。- 戻り値:
this
StreamReceiver.StreamReceiverOptionsBuilder
。
hashKeySerializer
public <HK,HV> StreamReceiver.StreamReceiverOptionsBuilder<K,MapRecord<K, hashKeySerializerHK, HV>> (RedisSerializationContext.SerializationPair<HK> pair) ハッシュキーシリアライザーを構成します。- パラメーター:
pair
- null であってはなりません。- 戻り値:
this
StreamReceiver.StreamReceiverOptionsBuilder
。
hashValueSerializer
public <HK,HV> StreamReceiver.StreamReceiverOptionsBuilder<K,MapRecord<K, hashValueSerializerHK, HV>> (RedisSerializationContext.SerializationPair<HV> pair) ハッシュ値シリアライザーを構成します。- パラメーター:
pair
- null であってはなりません。- 戻り値:
this
StreamReceiver.StreamReceiverOptionsBuilder
。
targetType
public <NV> StreamReceiver.StreamReceiverOptionsBuilder<K,ObjectRecord<K, targetTypeNV>> (ClassSE<NV> targetType) ハッシュターゲット型を構成します。放出されたRecord
型をObjectRecord
に変更します。- パラメーター:
targetType
- null であってはなりません。- 戻り値:
this
StreamReceiver.StreamReceiverOptionsBuilder
。
objectMapper
public <NV> StreamReceiver.StreamReceiverOptionsBuilder<K,ObjectRecord<K, objectMapperNV>> (HashMapper<NV, ?, ?> hashMapper) ハッシュマッパーを構成します。放出されたRecord
型をObjectRecord
に変更します。- パラメーター:
hashMapper
- null であってはなりません。- 戻り値:
this
StreamReceiver.StreamReceiverOptionsBuilder
。
build
新しいStreamReceiver.StreamReceiverOptions
を構築します。- 戻り値:
- 新しい
StreamReceiver.StreamReceiverOptions
。