Package 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	Description
static <K> StreamMessageListenerContainer.StreamReadRequestBuilder<K>	builder(StreamOffset<K> offset)
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 Details

builder

public static <K>
StreamMessageListenerContainer.StreamReadRequestBuilder<K> builder(StreamOffset<K> offset)

Returns:

a new builder for StreamMessageListenerContainer.StreamReadRequest.

getStreamOffset

public StreamOffset<K> getStreamOffset()

getErrorHandler

@Nullable
public ErrorHandler getErrorHandler()

getCancelSubscriptionOnError

public Predicate<Throwable> getCancelSubscriptionOnError()