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

メソッドの詳細

• pollTimeout

  public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> pollTimeout(DurationSE pollTimeout)

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

  パラメーター:

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

  戻り値:

  this StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder。

• batchSize

  public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> batchSize(int messagesPerPoll)

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

  パラメーター:

  messagesPerPoll - ゼロより大きくすることはできません。

  戻り値:

  this StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder。

• executor

  public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> executor(ExecutorSE executor)

  ストリームポーリング Task を実行するように ExecutorSE を構成します。

  パラメーター:

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

  戻り値:

  this StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder。

• errorHandler

  public StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,V> errorHandler(ErrorHandler errorHandler)

  errorsSE で通知されるように ErrorHandler を構成します。

  パラメーター:

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

  戻り値:

  this StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder。

• serializer

  public <T> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<T,MapRecord<T,T,T>> serializer(RedisSerializer<T> serializer)

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

  パラメーター:

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

  戻り値:

  this StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder。

• keySerializer

  public <NK, NV extends Record<NK, ?>> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<NK,NV> keySerializer(RedisSerializer<NK> serializer)

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

  パラメーター:

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

  戻り値:

  this StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder。

• hashKeySerializer

  public <HK, HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,MapRecord<K,HK,HV>> hashKeySerializer(RedisSerializer<HK> serializer)

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

  パラメーター:

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

  戻り値:

  this StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder。

• hashValueSerializer

  public <HK, HV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,MapRecord<K,HK,HV>> hashValueSerializer(RedisSerializer<HV> serializer)

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

  パラメーター:

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

  戻り値:

  this StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder。

• targetType

  public <NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,ObjectRecord<K,NV>> targetType(ClassSE<NV> targetType)

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

  パラメーター:

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

  戻り値:

  this StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder。

• objectMapper

  public <NV> StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder<K,ObjectRecord<K,NV>> objectMapper(HashMapper<NV,?,?> hashMapper)

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

  パラメーター:

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

  戻り値:

  this StreamMessageListenerContainer.StreamMessageListenerContainerOptionsBuilder。

• build

  public StreamMessageListenerContainer.StreamMessageListenerContainerOptions<K,V> build()

  新しい StreamMessageListenerContainer.StreamMessageListenerContainerOptions を構築します。

  戻り値:

  新しい StreamMessageListenerContainer.StreamMessageListenerContainerOptions。