クラス StreamMessageListenerContainer.StreamReadRequestBuilder<K>

メソッドの詳細

• errorHandler

  public StreamMessageListenerContainer.StreamReadRequestBuilder<K> errorHandler(ErrorHandler errorHandler)

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

  パラメーター:

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

  戻り値:

  this StreamMessageListenerContainer.StreamReadRequestBuilder。

• cancelOnError

  public StreamMessageListenerContainer.StreamReadRequestBuilder<K> cancelOnError(PredicateSE<ThrowableSE> cancelSubscriptionOnError)

  errorsSE で通知されるキャンセル PredicateSE を構成します。PredicateSE の結果は、true を返すことによってサブスクリプションをキャンセルするかどうかを決定します。

  パラメーター:

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

  戻り値:

  this StreamMessageListenerContainer.StreamReadRequestBuilder。

• consumer

  public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> consumer(Consumer consumer)

  コンシューマーグループ内のストリームメッセージを消費するように Consumer を構成します。

  パラメーター:

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

  戻り値:

  新しい StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder。

• build

  public StreamMessageListenerContainer.StreamReadRequest<K> build()

  StreamMessageListenerContainer.StreamReadRequest の新しいインスタンスを作成します。

  戻り値:

  StreamMessageListenerContainer.StreamReadRequest の新しいインスタンス。