Package | Description |
---|---|
org.springframework.data.redis.connection |
Connection package providing low-level abstractions for interacting with the various Redis 'drivers'/libraries.
|
org.springframework.data.redis.connection.stream |
Data structures and interfaces to interact with Redis Streams.
|
org.springframework.data.redis.core |
Core package for integrating Redis with Spring concepts.
|
org.springframework.data.redis.stream |
Modifier and Type | Method and Description |
---|---|
Consumer |
ReactiveStreamCommands.ReadCommand.getConsumer() |
Modifier and Type | Method and Description |
---|---|
ReactiveStreamCommands.ReadCommand |
ReactiveStreamCommands.ReadCommand.as(Consumer consumer)
Applies a
Consumer . |
static ReactiveStreamCommands.GroupCommand |
ReactiveStreamCommands.GroupCommand.deleteConsumer(Consumer consumer) |
Boolean |
RedisStreamCommands.xGroupDelConsumer(byte[] key,
Consumer consumer)
Delete a consumer from a consumer group.
|
default Boolean |
DefaultedRedisConnection.xGroupDelConsumer(byte[] key,
Consumer consumer)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
Boolean |
DefaultStringRedisConnection.xGroupDelConsumer(byte[] key,
Consumer consumer) |
default reactor.core.publisher.Mono<String> |
ReactiveStreamCommands.xGroupDelConsumer(ByteBuffer key,
Consumer consumer)
Delete a consumer from a consumer group.
|
Boolean |
StringRedisConnection.xGroupDelConsumer(String key,
Consumer consumer)
Delete a consumer from a consumer group.
|
Boolean |
DefaultStringRedisConnection.xGroupDelConsumer(String key,
Consumer consumer) |
default List<ByteRecord> |
RedisStreamCommands.xReadGroup(Consumer consumer,
StreamOffset<byte[]>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default List<ByteRecord> |
DefaultedRedisConnection.xReadGroup(Consumer consumer,
StreamOffset<byte[]>... streams)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xReadGroup(Consumer consumer,
StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
List<ByteRecord> |
RedisStreamCommands.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default List<ByteRecord> |
DefaultedRedisConnection.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<byte[]>... streams)
Deprecated.
in favor of
RedisConnection.streamCommands() }. |
List<ByteRecord> |
DefaultStringRedisConnection.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<byte[]>... streams) |
default reactor.core.publisher.Flux<ByteBufferRecord> |
ReactiveStreamCommands.xReadGroup(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<ByteBuffer>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default List<StringRecord> |
StringRedisConnection.xReadGroupAsString(Consumer consumer,
StreamOffset<String>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default List<StringRecord> |
StringRedisConnection.xReadGroupAsString(Consumer consumer,
StreamOffset<String> stream)
Read records from one or more
StreamOffset s using a consumer group. |
List<StringRecord> |
StringRedisConnection.xReadGroupAsString(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<String>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
List<StringRecord> |
DefaultStringRedisConnection.xReadGroupAsString(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<String>... streams) |
default List<StringRecord> |
StringRedisConnection.xReadGroupAsString(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<String> stream)
Read records from one or more
StreamOffset s using a consumer group. |
Constructor and Description |
---|
ReadCommand(List<StreamOffset<ByteBuffer>> streamOffsets,
StreamReadOptions readOptions,
Consumer consumer) |
Modifier and Type | Method and Description |
---|---|
static Consumer |
Consumer.from(String group,
String name)
Create a new consumer.
|
Modifier and Type | Method and Description |
---|---|
Boolean |
BoundStreamOperations.deleteConsumer(Consumer consumer)
Delete a consumer from a consumer group.
|
reactor.core.publisher.Mono<String> |
ReactiveStreamOperations.deleteConsumer(K key,
Consumer consumer)
Delete a consumer from a consumer group.
|
Boolean |
StreamOperations.deleteConsumer(K key,
Consumer consumer)
Delete a consumer from a consumer group.
|
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> |
ReactiveStreamOperations.read(Class<V> targetType,
Consumer consumer,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group as ObjectRecord . |
default <V> List<ObjectRecord<K,V>> |
StreamOperations.read(Class<V> targetType,
Consumer consumer,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group as ObjectRecord . |
default <V> reactor.core.publisher.Flux<ObjectRecord<K,V>> |
ReactiveStreamOperations.read(Class<V> targetType,
Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group as ObjectRecord . |
default <V> List<ObjectRecord<K,V>> |
StreamOperations.read(Class<V> targetType,
Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group as ObjectRecord . |
default List<MapRecord<K,HK,HV>> |
BoundStreamOperations.read(Consumer consumer,
ReadOffset readOffset)
Read records starting from
ReadOffset . using a consumer group. |
default reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.read(Consumer consumer,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
default List<MapRecord<K,HK,HV>> |
StreamOperations.read(Consumer consumer,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
List<MapRecord<K,HK,HV>> |
BoundStreamOperations.read(Consumer consumer,
StreamReadOptions readOptions,
ReadOffset readOffset)
Read records starting from
ReadOffset . using a consumer group. |
reactor.core.publisher.Flux<MapRecord<K,HK,HV>> |
ReactiveStreamOperations.read(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
List<MapRecord<K,HK,HV>> |
StreamOperations.read(Consumer consumer,
StreamReadOptions readOptions,
StreamOffset<K>... streams)
Read records from one or more
StreamOffset s using a consumer group. |
Modifier and Type | Method and Description |
---|---|
Consumer |
StreamMessageListenerContainer.ConsumerStreamReadRequest.getConsumer() |
Modifier and Type | Method and Description |
---|---|
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
StreamMessageListenerContainer.StreamReadRequestBuilder.consumer(Consumer consumer)
Configure a
Consumer to consume stream messages within a consumer group. |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder<K> |
StreamMessageListenerContainer.ConsumerStreamReadRequestBuilder.consumer(Consumer consumer)
Configure a
Consumer to consume stream messages within a consumer group. |
reactor.core.publisher.Flux<V> |
StreamReceiver.receive(Consumer consumer,
StreamOffset<K> streamOffset)
|
default Subscription |
StreamMessageListenerContainer.receive(Consumer consumer,
StreamOffset<K> streamOffset,
StreamListener<K,V> listener)
Register a new subscription for a Redis Stream.
|
reactor.core.publisher.Flux<V> |
StreamReceiver.receiveAutoAck(Consumer consumer,
StreamOffset<K> streamOffset)
|
default Subscription |
StreamMessageListenerContainer.receiveAutoAck(Consumer consumer,
StreamOffset<K> streamOffset,
StreamListener<K,V> listener)
Register a new subscription for a Redis Stream.
|
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.