org.springframework.data.redis.stream

Class StreamMessageListenerContainer.StreamReadRequest<K>

java.lang.Object

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

Type Parameters:

K - Stream key and Stream field type.

Direct Known Subclasses:

StreamMessageListenerContainer.ConsumerStreamReadRequest

Enclosing interface:

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

public static class StreamMessageListenerContainer.StreamReadRequest<K>
extends Object

Request to read a Redis Stream.

See Also:

StreamMessageListenerContainer.StreamReadRequestBuilder

Method Summary

Modifier and Type	Method and Description
Predicate<Throwable>	getCancelSubscriptionOnError()
ErrorHandler	getErrorHandler()
StreamOffset<K>	getStreamOffset()

Methods inherited from class java.lang.Object

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

Method Detail

getStreamOffset

public StreamOffset<K> getStreamOffset()

getErrorHandler

@Nullable
public ErrorHandler getErrorHandler()

getCancelSubscriptionOnError

public Predicate<Throwable> getCancelSubscriptionOnError()