| Package | Description |
|---|---|
| org.springframework.data.redis.stream |
| Modifier and Type | Method and Description |
|---|---|
default Subscription |
StreamMessageListenerContainer.receive(Consumer consumer,
StreamOffset<K> streamOffset,
StreamListener<K,V> listener)
Register a new subscription for a Redis Stream.
|
default Subscription |
StreamMessageListenerContainer.receive(StreamOffset<K> streamOffset,
StreamListener<K,V> listener)
Register a new subscription for a Redis Stream.
|
default Subscription |
StreamMessageListenerContainer.receiveAutoAck(Consumer consumer,
StreamOffset<K> streamOffset,
StreamListener<K,V> listener)
Register a new subscription for a Redis Stream.
|
Subscription |
StreamMessageListenerContainer.register(StreamMessageListenerContainer.StreamReadRequest<K> streamRequest,
StreamListener<K,V> listener)
Register a new subscription for a Redis Stream.
|
| Modifier and Type | Method and Description |
|---|---|
void |
StreamMessageListenerContainer.remove(Subscription subscription)
Unregister a given
Subscription from the container. |
Copyright © 2011–2023 Pivotal Software, Inc.. All rights reserved.