Package org.springframework.data.redis.stream

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.

See Also:

• StreamMessageListenerContainer.StreamReadRequestBuilder

Method Summary

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

Methods inherited from class org.springframework.data.redis.stream.StreamMessageListenerContainer.StreamReadRequest

builder, getCancelSubscriptionOnError, getErrorHandler, getStreamOffset

Methods inherited from class java.lang.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