クラスの使用
org.springframework.data.redis.stream.StreamReceiver.StreamReceiverOptionsBuilder
StreamReceiver.StreamReceiverOptionsBuilder を使用するパッケージ
org.springframework.data.redis.stream 内の StreamReceiver.StreamReceiverOptionsBuilder 使用
修飾子と型メソッド説明StreamReceiver.StreamReceiverOptionsBuilder.batchSize(int recordsPerPoll) 読み取り中にCOUNTオプションのバッチサイズを構成します。StreamReceiver.StreamReceiverOptions.builder()static <T> StreamReceiver.StreamReceiverOptionsBuilder<StringSE,ObjectRecord<StringSE, T>> StreamReceiver.StreamReceiverOptions.builder(HashMapper<T, byte[], byte[]> hashMapper) <HK,HV> StreamReceiver.StreamReceiverOptionsBuilder<K, MapRecord<K, HK, HV>> StreamReceiver.StreamReceiverOptionsBuilder.hashKeySerializer(RedisSerializationContext.SerializationPair<HK> pair) ハッシュキーシリアライザーを構成します。<HK,HV> StreamReceiver.StreamReceiverOptionsBuilder<K, MapRecord<K, HK, HV>> StreamReceiver.StreamReceiverOptionsBuilder.hashValueSerializer(RedisSerializationContext.SerializationPair<HV> pair) ハッシュ値シリアライザーを構成します。<NK,NV extends Record<NK, ?>>
StreamReceiver.StreamReceiverOptionsBuilder<NK,NV> StreamReceiver.StreamReceiverOptionsBuilder.keySerializer(RedisSerializationContext.SerializationPair<NK> pair) キーシリアライザーを構成します。StreamReceiver.StreamReceiverOptionsBuilder.objectMapper(HashMapper<NV, ?, ?> hashMapper) ハッシュマッパーを構成します。StreamReceiver.StreamReceiverOptionsBuilder.onErrorResume(FunctionSE<? super ThrowableSE, ? extends Publisher<VoidSE>> resumeFunction) ストリームのポーリングが失敗したときにメインシーケンスを再開するように再開FunctionSE を構成します。StreamReceiver.StreamReceiverOptionsBuilder.pollTimeout(DurationSE pollTimeout) 読み取り中にBLOCKオプションのポーリングタイムアウトを設定します。<T> StreamReceiver.StreamReceiverOptionsBuilder<T,MapRecord<T, T, T>> StreamReceiver.StreamReceiverOptionsBuilder.serializer(RedisSerializationContext.SerializationPair<T> pair) キー、ハッシュキー、ハッシュ値シリアライザーを構成します。<T> StreamReceiver.StreamReceiverOptionsBuilder<T,MapRecord<T, T, T>> StreamReceiver.StreamReceiverOptionsBuilder.serializer(RedisSerializationContext<T, ?> serializationContext) キー、ハッシュキー、ハッシュ値シリアライザーを構成します。StreamReceiver.StreamReceiverOptionsBuilder.targetType(ClassSE<NV> targetType) ハッシュターゲット型を構成します。