クラス StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K>
java.lang.ObjectSE
org.springframework.data.redis.stream.StreamMessageListenerContainer.StreamReadRequestBuilder<K>
org.springframework.data.redis.stream.StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K>
- 型パラメーター:
K- ストリームキーとストリームフィールド型。
- 含まれているインターフェース:
- StreamMessageListenerContainer < K , V はレコード < K , ?>> を継承します
public static class StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K>
extends StreamMessageListenerContainer.StreamReadRequestBuilder<K>
メソッドのサマリー
修飾子と型メソッド説明autoAcknowledge(boolean autoAck) ストリームメッセージを消費するための自動確認応答を設定します。build()StreamMessageListenerContainer.ConsumerStreamReadRequestの新しいインスタンスを作成します。cancelOnError(PredicateSE<ThrowableSE> cancelSubscriptionOnError) read, deserialization, and listener errorsSE で通知されるキャンセルPredicateSE を構成します。コンシューマーグループ内のストリームメッセージを消費するようにConsumerを構成します。errorHandler(ErrorHandler errorHandler) read, deserialization, and listener errorsSE で通知されるようにErrorHandlerを構成します。
メソッドの詳細
errorHandler
public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> errorHandler(ErrorHandler errorHandler) read, deserialization, and listener errorsSE で通知されるようにErrorHandlerを構成します。- オーバーライド:
- クラス
StreamMessageListenerContainer.StreamReadRequestBuilder<K>のerrorHandler - パラメーター:
errorHandler- null であってはなりません。- 戻り値:
thisStreamMessageListenerContainer.ConsumerStreamReadRequestBuilder。
cancelOnError
public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> cancelOnError(PredicateSE<ThrowableSE> cancelSubscriptionOnError) read, deserialization, and listener errorsSE で通知されるキャンセルPredicateSE を構成します。PredicateSE の結果は、true を返すことによってサブスクリプションをキャンセルするかどうかを決定します。- オーバーライド:
- クラス
StreamMessageListenerContainer.StreamReadRequestBuilder<K>のcancelOnError - パラメーター:
cancelSubscriptionOnError- null であってはなりません。- 戻り値:
thisStreamMessageListenerContainer.ConsumerStreamReadRequestBuilder。
consumer
public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> consumer(Consumer consumer) コンシューマーグループ内のストリームメッセージを消費するようにConsumerを構成します。- オーバーライド:
- クラス
StreamMessageListenerContainer.StreamReadRequestBuilder<K>のconsumer - パラメーター:
consumer- null であってはなりません。- 戻り値:
thisStreamMessageListenerContainer.ConsumerStreamReadRequestBuilder。
autoAcknowledge
public StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> autoAcknowledge(boolean autoAck) ストリームメッセージを消費するための自動確認応答を設定します。- パラメーター:
autoAck- 受信したメッセージを自動確認する場合は true（デフォルト）、外部確認の場合は false。- 戻り値:
thisStreamMessageListenerContainer.ConsumerStreamReadRequestBuilder。- 導入:
- 2.3
build
StreamMessageListenerContainer.ConsumerStreamReadRequestの新しいインスタンスを作成します。- オーバーライド:
- クラス
StreamMessageListenerContainer.StreamReadRequestBuilder<K>のbuild - 戻り値:
StreamMessageListenerContainer.ConsumerStreamReadRequestの新しいインスタンス。