Class StreamMessageListenerContainer.ConsumerStreamReadRequest<K>

java.lang.Object

org.springframework.data.redis.stream.StreamMessageListenerContainer.StreamReadRequest<K>

org.springframework.data.redis.stream.StreamMessageListenerContainer.ConsumerStreamReadRequest<K>

Type Parameters:

K - Stream key and Stream field type.

Enclosing interface:

StreamMessageListenerContainer<K, V extends Record<K,?>>

public static class StreamMessageListenerContainer.ConsumerStreamReadRequest<K>
extends StreamMessageListenerContainer.StreamReadRequest<K>

Request to read a Redis Stream with a Consumer.

Since:

2.2

Author:

Mark Paluch, Christoph Strobl, Christian Rest, DongCheol Kim, Su Ko

See Also:

• StreamMessageListenerContainer.StreamReadRequestBuilder

Method Summary

Modifier and Type	Method	Description
Consumer	getConsumer()
boolean	isAutoAcknowledge()

Methods inherited from class StreamMessageListenerContainer.StreamReadRequest

builder, getCancelSubscriptionOnError, getErrorHandler, getStreamOffset

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

getConsumer

public Consumer getConsumer()

isAutoAcknowledge

public boolean isAutoAcknowledge()

Returns:

Since:

2.3