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