クラス StreamReceiver.StreamReceiverOptionsBuilder<K, V はレコード <K, ?>> を継承します

方法の詳細

• pollTimeout

  public StreamReceiver.StreamReceiverOptionsBuilder<K,V> pollTimeout(DurationSE pollTimeout)

  読み取り中に BLOCK オプションのポーリングタイムアウトを設定します。

  パラメーター:

  pollTimeout - null または負であってはなりません。

  戻り値:

  this StreamReceiver.StreamReceiverOptionsBuilder。

• batchSize

  public StreamReceiver.StreamReceiverOptionsBuilder<K,V> batchSize(int recordsPerPoll)

  読み取り中に COUNT オプションのバッチサイズを構成します。

  パラメーター:

  recordsPerPoll - ゼロより大きくなければなりません。

  戻り値:

  this StreamReceiver.StreamReceiverOptionsBuilder。

• onErrorResume

  public StreamReceiver.StreamReceiverOptionsBuilder<K,V> onErrorResume(FunctionSE<? super ThrowableSE,? extends org.reactivestreams.Publisher<VoidSE>> resumeFunction)

  ストリームのポーリングが失敗したときにメインシーケンスを再開するように再開 FunctionSE を構成します。この関数は、エラーを抑制して再開するか、エラーを発行して受信を停止することでメインシーケンスを失敗させることができます。受信エラー (Redis エラー、直列化エラー) は、デフォルトで受信を停止します。

  パラメーター:

  resumeFunction - null であってはなりません。

  戻り値:

  this StreamReceiver.StreamReceiverOptionsBuilder。

  導入:

  2.x

  関連事項:

  • Flux.onErrorResume(Function)

• serializer

  public <T> StreamReceiver.StreamReceiverOptionsBuilder<T,MapRecord<T,T,T>> serializer(RedisSerializationContext.SerializationPair<T> pair)

  キー、ハッシュキー、ハッシュ値シリアライザーを構成します。

  パラメーター:

  pair - null であってはなりません。

  戻り値:

  this StreamReceiver.StreamReceiverOptionsBuilder。

• serializer

  public <T> StreamReceiver.StreamReceiverOptionsBuilder<T,MapRecord<T,T,T>> serializer(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,HK,HV>> hashKeySerializer(RedisSerializationContext.SerializationPair<HK> pair)

  ハッシュキーシリアライザーを構成します。

  パラメーター:

  pair - null であってはなりません。

  戻り値:

  this StreamReceiver.StreamReceiverOptionsBuilder。

• hashValueSerializer

  public <HK, HV> StreamReceiver.StreamReceiverOptionsBuilder<K,MapRecord<K,HK,HV>> hashValueSerializer(RedisSerializationContext.SerializationPair<HV> pair)

  ハッシュ値シリアライザーを構成します。

  パラメーター:

  pair - null であってはなりません。

  戻り値:

  this StreamReceiver.StreamReceiverOptionsBuilder。

• targetType

  public <NV> StreamReceiver.StreamReceiverOptionsBuilder<K,ObjectRecord<K,NV>> targetType(ClassSE<NV> targetType)

  ハッシュターゲット型を構成します。放出された Record 型を ObjectRecord に変更します。

  パラメーター:

  targetType - null であってはなりません。

  戻り値:

  this StreamReceiver.StreamReceiverOptionsBuilder。

• objectMapper

  public <NV> StreamReceiver.StreamReceiverOptionsBuilder<K,ObjectRecord<K,NV>> objectMapper(HashMapper<NV,?,?> hashMapper)

  ハッシュマッパーを構成します。放出された Record 型を ObjectRecord に変更します。

  パラメーター:

  hashMapper - null であってはなりません。

  戻り値:

  this StreamReceiver.StreamReceiverOptionsBuilder。

• build

  public StreamReceiver.StreamReceiverOptions<K,V> build()

  新しい StreamReceiver.StreamReceiverOptions を構築します。

  戻り値:

  新しい StreamReceiver.StreamReceiverOptions。