Package org.springframework.data.redis.connection

Interface ReactiveStreamCommands

All Known Subinterfaces:

ReactiveClusterStreamCommands

public interface ReactiveStreamCommands

Stream-specific Redis commands executed using reactive infrastructure.

Since:

2.2

Author:

Mark Paluch, Christoph Strobl, Tugdual Grall, Dengliming, Mark John Moreno

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	ReactiveStreamCommands.AcknowledgeCommand	XACK command parameters.
static class	ReactiveStreamCommands.AddStreamRecord	XADD command parameters.
static class	ReactiveStreamCommands.DeleteCommand	XDEL command parameters.
static class	ReactiveStreamCommands.GroupCommand
static class	ReactiveStreamCommands.PendingRecordsCommand	Value Object holding parameters for obtaining pending messages.
static class	ReactiveStreamCommands.RangeCommand	XRANGE/XREVRANGE command parameters.
static class	ReactiveStreamCommands.ReadCommand	XRANGE/XREVRANGE command parameters.
static class	ReactiveStreamCommands.TrimCommand	XTRIM command parameters.
static class	ReactiveStreamCommands.XClaimCommand	XCLAIM command parameters.
static class	ReactiveStreamCommands.XInfoCommand

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,reactor.core.publisher.Flux<ByteBufferRecord>>>	read(org.reactivestreams.Publisher<ReactiveStreamCommands.ReadCommand> commands)	Read records from one or more StreamOffsets.
default reactor.core.publisher.Mono<Long>	xAck(ByteBuffer key, String group, String... recordIds)	Acknowledge one or more records as processed.
default reactor.core.publisher.Mono<Long>	xAck(ByteBuffer key, String group, RecordId... recordIds)	Acknowledge one or more records as processed.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStreamCommands.AcknowledgeCommand,Long>>	xAck(org.reactivestreams.Publisher<ReactiveStreamCommands.AcknowledgeCommand> commands)	Acknowledge one or more records as processed.
default reactor.core.publisher.Mono<RecordId>	xAdd(ByteBuffer key, Map<ByteBuffer,ByteBuffer> body)	Add stream record with given body to key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,RecordId>>	xAdd(org.reactivestreams.Publisher<ReactiveStreamCommands.AddStreamRecord> commands)	Add stream record with given body to key.
default reactor.core.publisher.Mono<RecordId>	xAdd(ByteBufferRecord record)	Add stream record with given body to key.
default reactor.core.publisher.Flux<ByteBufferRecord>	xClaim(ByteBuffer key, String group, String newOwner, Duration minIdleTime, RecordId... recordIds)	Change the ownership of a pending message to the given new consumer.
default reactor.core.publisher.Flux<ByteBufferRecord>	xClaim(ByteBuffer key, String group, String newOwner, RedisStreamCommands.XClaimOptions options)	Change the ownership of a pending message to the given new consumer.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<ByteBufferRecord>>>	xClaim(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)	Change the ownership of a pending message to the given new consumer.
default reactor.core.publisher.Flux<RecordId>	xClaimJustId(ByteBuffer key, String group, String newOwner, RedisStreamCommands.XClaimOptions options)	Change the ownership of a pending message to the given new consumer without increasing the delivered count.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<RecordId>>>	xClaimJustId(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)	Change the ownership of a pending message to the given new consumer without increasing the delivered count.
default reactor.core.publisher.Mono<Long>	xDel(ByteBuffer key, String... recordIds)	Removes the specified entries from the stream.
default reactor.core.publisher.Mono<Long>	xDel(ByteBuffer key, RecordId... recordIds)	Removes the specified entries from the stream.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.DeleteCommand,Long>>	xDel(org.reactivestreams.Publisher<ReactiveStreamCommands.DeleteCommand> commands)	Removes the specified entries from the stream.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,String>>	xGroup(org.reactivestreams.Publisher<ReactiveStreamCommands.GroupCommand> commands)	Execute the given ReactiveStreamCommands.GroupCommand to create, destroy,... groups.
default reactor.core.publisher.Mono<String>	xGroup(ReactiveStreamCommands.GroupCommand command)	Execute the given ReactiveStreamCommands.GroupCommand to create, destroy,... groups.
default reactor.core.publisher.Mono<String>	xGroupCreate(ByteBuffer key, String groupName, ReadOffset readOffset)	Create a consumer group.
default reactor.core.publisher.Mono<String>	xGroupCreate(ByteBuffer key, String groupName, ReadOffset readOffset, boolean mkStream)	Create a consumer group.
default reactor.core.publisher.Mono<String>	xGroupDelConsumer(ByteBuffer key, String groupName, String consumerName)	Delete a consumer from a consumer group.
default reactor.core.publisher.Mono<String>	xGroupDelConsumer(ByteBuffer key, Consumer consumer)	Delete a consumer from a consumer group.
default reactor.core.publisher.Mono<String>	xGroupDestroy(ByteBuffer key, String groupName)	Destroy a consumer group.
default reactor.core.publisher.Mono<StreamInfo.XInfoStream>	xInfo(ByteBuffer key)	Obtain general information about the stream stored at the specified key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,StreamInfo.XInfoStream>>	xInfo(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)	Obtain general information about the stream stored at the specified key.
default reactor.core.publisher.Flux<StreamInfo.XInfoConsumer>	xInfoConsumers(ByteBuffer key, String groupName)	Obtain information about every consumer in a specific consumer group for the stream stored at the specified key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoConsumer>>>	xInfoConsumers(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)	Obtain information about every consumer in a specific consumer group for the stream stored at the specified key.
default reactor.core.publisher.Flux<StreamInfo.XInfoGroup>	xInfoGroups(ByteBuffer key)	Obtain general information about the stream stored at the specified key.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoGroup>>>	xInfoGroups(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)	Obtain general information about the stream stored at the specified key.
default reactor.core.publisher.Mono<Long>	xLen(ByteBuffer key)	Get the size of the stream stored at key.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	xLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)	Get the size of the stream stored at ReactiveRedisConnection.KeyCommand.getKey()
default reactor.core.publisher.Mono<PendingMessagesSummary>	xPending(ByteBuffer key, String groupName)	Obtain the PendingMessagesSummary for a given consumer group.
default reactor.core.publisher.Mono<PendingMessages>	xPending(ByteBuffer key, String groupName, String consumerName)	Obtained detailed information about all pending messages for a given consumer.
default reactor.core.publisher.Mono<PendingMessages>	xPending(ByteBuffer key, String groupName, String consumerName, org.springframework.data.domain.Range<?> range, Long count)	Obtain detailed information about pending messages for a given Range and consumer within a consumer group.
default reactor.core.publisher.Mono<PendingMessages>	xPending(ByteBuffer key, String groupName, org.springframework.data.domain.Range<?> range, Long count)	Obtain detailed information about pending messages for a given Range within a consumer group.
default reactor.core.publisher.Mono<PendingMessages>	xPending(ByteBuffer key, Consumer consumer)	Obtained detailed information about all pending messages for a given Consumer.
default reactor.core.publisher.Mono<PendingMessages>	xPending(ByteBuffer key, Consumer consumer, org.springframework.data.domain.Range<?> range, Long count)	Obtain detailed information about pending messages for a given Range and Consumer within a consumer group.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessages>>	xPending(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands)	Obtain detailed information about pending messages applying given options.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessagesSummary>>	xPendingSummary(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands)	Obtain the PendingMessagesSummary for a given consumer group.
default reactor.core.publisher.Flux<ByteBufferRecord>	xRange(ByteBuffer key, org.springframework.data.domain.Range<String> range)	Read records from a stream within a specific Range.
default reactor.core.publisher.Flux<ByteBufferRecord>	xRange(ByteBuffer key, org.springframework.data.domain.Range<String> range, Limit limit)	Read records from a stream within a specific Range applying a Limit.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>>	xRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)	Read records from a stream within a specific Range applying a Limit.
default reactor.core.publisher.Flux<ByteBufferRecord>	xRead(StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets.
default reactor.core.publisher.Flux<ByteBufferRecord>	xRead(StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets.
default reactor.core.publisher.Flux<ByteBufferRecord>	xReadGroup(Consumer consumer, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets using a consumer group.
default reactor.core.publisher.Flux<ByteBufferRecord>	xReadGroup(Consumer consumer, StreamReadOptions readOptions, StreamOffset<ByteBuffer>... streams)	Read records from one or more StreamOffsets using a consumer group.
default reactor.core.publisher.Flux<ByteBufferRecord>	xRevRange(ByteBuffer key, org.springframework.data.domain.Range<String> range)	Read records from a stream within a specific Range in reverse order.
default reactor.core.publisher.Flux<ByteBufferRecord>	xRevRange(ByteBuffer key, org.springframework.data.domain.Range<String> range, Limit limit)	Read records from a stream within a specific Range applying a Limit in reverse order.
reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>>	xRevRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)	Read records from a stream within a specific Range applying a Limit in reverse order.
default reactor.core.publisher.Mono<Long>	xTrim(ByteBuffer key, long count)	Trims the stream to count elements.
default reactor.core.publisher.Mono<Long>	xTrim(ByteBuffer key, long count, boolean approximateTrimming)	Trims the stream to count elements.
reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>>	xTrim(org.reactivestreams.Publisher<ReactiveStreamCommands.TrimCommand> commands)	Trims the stream to count elements.

Method Details

xAck

default reactor.core.publisher.Mono<Long> xAck(ByteBuffer key,
 String group,
 String... recordIds)

Acknowledge one or more records as processed.

Parameters:

key - the stream key.

group - name of the consumer group.

recordIds - record Id's to acknowledge.

Returns:

Mono emitting the nr of acknowledged messages.

See Also:

• Redis Documentation: XADD

xAck

default reactor.core.publisher.Mono<Long> xAck(ByteBuffer key,
 String group,
 RecordId... recordIds)

Acknowledge one or more records as processed.

Parameters:

key - the stream key.

group - name of the consumer group.

recordIds - record Id's to acknowledge.

Returns:

Mono emitting the nr of acknowledged messages.

See Also:

• Redis Documentation: XADD

xAck

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveStreamCommands.AcknowledgeCommand,Long>> xAck(org.reactivestreams.Publisher<ReactiveStreamCommands.AcknowledgeCommand> commands)

Acknowledge one or more records as processed.

Parameters:

commands - must not be null.

Returns:

Flux emitting the nr of acknowledged messages per ReactiveStreamCommands.AcknowledgeCommand.

See Also:

• Redis Documentation: XACK

xAdd

default reactor.core.publisher.Mono<RecordId> xAdd(ByteBuffer key,
 Map<ByteBuffer,ByteBuffer> body)

Add stream record with given body to key.

Parameters:

key - must not be null.

body - must not be null.

Returns:

Mono emitting the server generated id.

See Also:

• Redis Documentation: XADD

xAdd

default reactor.core.publisher.Mono<RecordId> xAdd(ByteBufferRecord record)

Add stream record with given body to key.

Parameters:

record - must not be null.

Returns:

Mono the id.

See Also:

• Redis Documentation: XADD

xAdd

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.AddStreamRecord,RecordId>> xAdd(org.reactivestreams.Publisher<ReactiveStreamCommands.AddStreamRecord> commands)

Add stream record with given body to key.

Parameters:

commands - must not be null.

Returns:

Flux emitting the RecordId on by for for the given ReactiveStreamCommands.AddStreamRecord commands.

See Also:

• Redis Documentation: XADD

xClaimJustId

default reactor.core.publisher.Flux<RecordId> xClaimJustId(ByteBuffer key,
 String group,
 String newOwner,
 RedisStreamCommands.XClaimOptions options)

Change the ownership of a pending message to the given new consumer without increasing the delivered count.

Parameters:

key - the key the stream is stored at.

group - the name of the consumer group.

newOwner - the name of the new consumer.

options - must not be null.

Returns:

a Flux emitting is that changed user.

Since:

2.3

See Also:

• Redis Documentation: XCLAIM

xClaimJustId

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<RecordId>>> xClaimJustId(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)

Change the ownership of a pending message to the given new consumer without increasing the delivered count.

Parameters:

commands - must not be null.

Returns:

a Flux emitting is that changed user.

Since:

2.3

See Also:

• Redis Documentation: XCLAIM

xClaim

default reactor.core.publisher.Flux<ByteBufferRecord> xClaim(ByteBuffer key,
 String group,
 String newOwner,
 Duration minIdleTime,
 RecordId... recordIds)

Change the ownership of a pending message to the given new consumer.

Parameters:

key - the key the stream is stored at.

group - the name of the consumer group.

newOwner - the name of the new consumer.

minIdleTime - must not be null.

recordIds - must not be null.

Returns:

a Flux emitting ByteBufferRecord that changed user.

Since:

2.3

See Also:

• Redis Documentation: XCLAIM

xClaim

default reactor.core.publisher.Flux<ByteBufferRecord> xClaim(ByteBuffer key,
 String group,
 String newOwner,
 RedisStreamCommands.XClaimOptions options)

Change the ownership of a pending message to the given new consumer.

Parameters:

key - the key the stream is stored at.

group - the name of the consumer group.

newOwner - the name of the new consumer.

options - must not be null.

Returns:

a Flux emitting ByteBufferRecord that changed user.

Since:

2.3

See Also:

• Redis Documentation: XCLAIM

xClaim

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XClaimCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> xClaim(org.reactivestreams.Publisher<ReactiveStreamCommands.XClaimCommand> commands)

Change the ownership of a pending message to the given new consumer.

Parameters:

commands - must not be null.

Returns:

Since:

2.3

See Also:

• Redis Documentation: XCLAIM

xDel

default reactor.core.publisher.Mono<Long> xDel(ByteBuffer key,
 String... recordIds)

Removes the specified entries from the stream. Returns the number of items deleted, that may be different from the number of IDs passed in case certain IDs do not exist.

Parameters:

key - the stream key.

recordIds - stream record Id's.

Returns:

Mono emitting the number of removed entries.

See Also:

• Redis Documentation: XDEL

xDel

default reactor.core.publisher.Mono<Long> xDel(ByteBuffer key,
 RecordId... recordIds)

Removes the specified entries from the stream. Returns the number of items deleted, that may be different from the number of IDs passed in case certain IDs do not exist.

Parameters:

key - the stream key.

recordIds - stream record Id's.

Returns:

Mono emitting the number of removed entries.

See Also:

• Redis Documentation: XDEL

xDel

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.DeleteCommand,Long>> xDel(org.reactivestreams.Publisher<ReactiveStreamCommands.DeleteCommand> commands)

Removes the specified entries from the stream. Returns the number of items deleted, that may be different from the number of IDs passed in case certain IDs do not exist.

Parameters:

commands - must not be null.

Returns:

Mono emitting the number of removed entries.

See Also:

• Redis Documentation: XDEL

xLen

default reactor.core.publisher.Mono<Long> xLen(ByteBuffer key)

Get the size of the stream stored at key.

Parameters:

key - must not be null.

Returns:

Mono emitting the length of the stream.

See Also:

• Redis Documentation: XLEN

xLen

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> xLen(org.reactivestreams.Publisher<ReactiveRedisConnection.KeyCommand> commands)

Get the size of the stream stored at ReactiveRedisConnection.KeyCommand.getKey()

Parameters:

commands - must not be null.

Returns:

Flux emitting the length of the stream per ReactiveRedisConnection.KeyCommand.

See Also:

• Redis Documentation: XLEN

xPending

default reactor.core.publisher.Mono<PendingMessagesSummary> xPending(ByteBuffer key,
 String groupName)

Obtain the PendingMessagesSummary for a given consumer group.

Parameters:

key - the key the stream is stored at. Must not be null.

groupName - the name of the consumer group. Must not be null.

Returns:

Mono emitting a summary of pending messages within the given consumer group.

Since:

2.3

See Also:

• Redis Documentation: xpending

xPendingSummary

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessagesSummary>> xPendingSummary(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands)

Obtain the PendingMessagesSummary for a given consumer group.

Parameters:

commands - must not be null..

Returns:

Flux emitting a summary of pending messages within the given consumer group one by one.

Since:

2.3

See Also:

• Redis Documentation: xpending

xPending

@Nullable
default reactor.core.publisher.Mono<PendingMessages> xPending(ByteBuffer key,
 Consumer consumer)

Obtained detailed information about all pending messages for a given Consumer.

Parameters:

key - the key the stream is stored at. Must not be null.

consumer - the consumer to fetch PendingMessages for. Must not be null.

Returns:

Mono emitting pending messages for the given Consumer.

Since:

2.3

See Also:

• Redis Documentation: xpending

xPending

@Nullable
default reactor.core.publisher.Mono<PendingMessages> xPending(ByteBuffer key,
 String groupName,
 String consumerName)

Obtained detailed information about all pending messages for a given consumer.

Parameters:

key - the key the stream is stored at. Must not be null.

groupName - the name of the consumer group. Must not be null.

consumerName - the consumer to fetch PendingMessages for. Must not be null.

Returns:

Mono emitting pending messages for the given Consumer.

Since:

2.3

See Also:

• Redis Documentation: xpending

xPending

default reactor.core.publisher.Mono<PendingMessages> xPending(ByteBuffer key,
 String groupName,
 org.springframework.data.domain.Range<?> range,
 Long count)

Obtain detailed information about pending messages for a given Range within a consumer group.

Parameters:

key - the key the stream is stored at. Must not be null.

groupName - the name of the consumer group. Must not be null.

range - the range of messages ids to search within. Must not be null.

count - limit the number of results. Must not be null.

Returns:

Mono emitting pending messages for the given consumer group. transaction.

Since:

2.3

See Also:

• Redis Documentation: xpending

xPending

default reactor.core.publisher.Mono<PendingMessages> xPending(ByteBuffer key,
 Consumer consumer,
 org.springframework.data.domain.Range<?> range,
 Long count)

Obtain detailed information about pending messages for a given Range and Consumer within a consumer group.

Parameters:

key - the key the stream is stored at. Must not be null.

consumer - the name of the Consumer. Must not be null.

range - the range of messages ids to search within. Must not be null.

count - limit the number of results. Must not be null.

Returns:

Mono emitting pending messages for the given Consumer.

Since:

2.3

See Also:

• Redis Documentation: xpending

xPending

default reactor.core.publisher.Mono<PendingMessages> xPending(ByteBuffer key,
 String groupName,
 String consumerName,
 org.springframework.data.domain.Range<?> range,
 Long count)

Obtain detailed information about pending messages for a given Range and consumer within a consumer group.

Parameters:

key - the key the stream is stored at. Must not be null.

groupName - the name of the consumer group. Must not be null.

consumerName - the name of the consumer. Must not be null.

range - the range of messages ids to search within. Must not be null.

count - limit the number of results. Must not be null.

Returns:

Mono emitting pending messages for the given consumer in given consumer group.

Since:

2.3

See Also:

• Redis Documentation: xpending

xPending

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.PendingRecordsCommand,PendingMessages>> xPending(org.reactivestreams.Publisher<ReactiveStreamCommands.PendingRecordsCommand> commands)

Obtain detailed information about pending messages applying given options.

Parameters:

commands - must not be null.

Returns:

Flux emitting pending messages matching given criteria.

Since:

2.3

See Also:

• Redis Documentation: xpending

xRange

default reactor.core.publisher.Flux<ByteBufferRecord> xRange(ByteBuffer key,
 org.springframework.data.domain.Range<String> range)

Read records from a stream within a specific Range.

Parameters:

key - the stream key.

range - must not be null.

Returns:

Flux emitting with members of the stream.

See Also:

• Redis Documentation: XRANGE

xRange

default reactor.core.publisher.Flux<ByteBufferRecord> xRange(ByteBuffer key,
 org.springframework.data.domain.Range<String> range,
 Limit limit)

Read records from a stream within a specific Range applying a Limit.

Parameters:

key - the stream key.

range - must not be null.

limit - must not be null.

Returns:

Flux emitting with members of the stream.

See Also:

• Redis Documentation: XRANGE

xRange

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> xRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)

Read records from a stream within a specific Range applying a Limit.

Parameters:

commands - must not be null.

Returns:

Flux emitting with members of the stream per ReactiveStreamCommands.RangeCommand.

See Also:

• Redis Documentation: XRANGE

xRead

default reactor.core.publisher.Flux<ByteBufferRecord> xRead(StreamOffset<ByteBuffer>... streams)

Read records from one or more StreamOffsets.

Parameters:

streams - the streams to read from.

Returns:

Flux emitting with members of the stream.

See Also:

• Redis Documentation: XREAD

xRead

default reactor.core.publisher.Flux<ByteBufferRecord> xRead(StreamReadOptions readOptions,
 StreamOffset<ByteBuffer>... streams)

Read records from one or more StreamOffsets.

Parameters:

readOptions - read arguments.

streams - the streams to read from.

Returns:

Flux emitting with members of the stream.

See Also:

• Redis Documentation: XREAD

read

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.ReadCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> read(org.reactivestreams.Publisher<ReactiveStreamCommands.ReadCommand> commands)

Read records from one or more StreamOffsets.

Parameters:

commands - must not be null.

Returns:

Flux emitting the members of the stream per ReactiveStreamCommands.ReadCommand.

See Also:

• Redis Documentation: XREAD
• Redis Documentation: XREADGROUP

xInfo

default reactor.core.publisher.Mono<StreamInfo.XInfoStream> xInfo(ByteBuffer key)

Obtain general information about the stream stored at the specified key.

Parameters:

key - the key the stream is stored at.

Returns:

a Mono emitting StreamInfo.XInfoStream when ready.

Since:

2.3

xInfo

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,StreamInfo.XInfoStream>> xInfo(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)

Obtain general information about the stream stored at the specified key.

Parameters:

commands - must not be null.

Returns:

never null.

Since:

2.3

xInfoGroups

default reactor.core.publisher.Flux<StreamInfo.XInfoGroup> xInfoGroups(ByteBuffer key)

Obtain general information about the stream stored at the specified key.

Parameters:

key - the key the stream is stored at.

Returns:

a Flux emitting consumer group info one by one.

Since:

2.3

xInfoGroups

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoGroup>>> xInfoGroups(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)

Obtain general information about the stream stored at the specified key.

Parameters:

commands - must not be null.

Returns:

never null.

Since:

2.3

xInfoConsumers

default reactor.core.publisher.Flux<StreamInfo.XInfoConsumer> xInfoConsumers(ByteBuffer key,
 String groupName)

Obtain information about every consumer in a specific consumer group for the stream stored at the specified key.

Parameters:

key - the key the stream is stored at.

groupName - name of the consumer group.

Returns:

a Flux emitting consumer info one by one.

Since:

2.3

xInfoConsumers

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.XInfoCommand,reactor.core.publisher.Flux<StreamInfo.XInfoConsumer>>> xInfoConsumers(org.reactivestreams.Publisher<ReactiveStreamCommands.XInfoCommand> commands)

Obtain information about every consumer in a specific consumer group for the stream stored at the specified key.

Parameters:

commands - must not be null.

Returns:

never null.

Since:

2.3

xGroupCreate

default reactor.core.publisher.Mono<String> xGroupCreate(ByteBuffer key,
 String groupName,
 ReadOffset readOffset)

Create a consumer group.

Parameters:

key - key the key the stream is stored at.

groupName - name of the consumer group to create.

readOffset - the offset to start at.

Returns:

the Mono emitting ok if successful.

xGroupCreate

default reactor.core.publisher.Mono<String> xGroupCreate(ByteBuffer key,
 String groupName,
 ReadOffset readOffset,
 boolean mkStream)

Create a consumer group.

Parameters:

key - key the key the stream is stored at.

groupName - name of the consumer group to create.

readOffset - the offset to start at.

mkStream - if true the group will create the stream if needed (MKSTREAM)

Returns:

the Mono emitting ok if successful.

Since:

2.3

xGroupDelConsumer

@Nullable
default reactor.core.publisher.Mono<String> xGroupDelConsumer(ByteBuffer key,
 String groupName,
 String consumerName)

Delete a consumer from a consumer group.

Parameters:

key - the key the stream is stored at.

groupName - the name of the group to remove the consumer from.

consumerName - the name of the consumer to remove from the group.

Returns:

the Mono emitting ok if successful.

xGroupDelConsumer

default reactor.core.publisher.Mono<String> xGroupDelConsumer(ByteBuffer key,
 Consumer consumer)

Delete a consumer from a consumer group.

Parameters:

key - the key the stream is stored at.

consumer - the Consumer.

Returns:

the Mono emitting ok if successful.

xGroupDestroy

@Nullable
default reactor.core.publisher.Mono<String> xGroupDestroy(ByteBuffer key,
 String groupName)

Destroy a consumer group.

Parameters:

key - the key the stream is stored at.

groupName - name of the consumer group.

Returns:

the Mono emitting ok if successful.

xGroup

default reactor.core.publisher.Mono<String> xGroup(ReactiveStreamCommands.GroupCommand command)

Execute the given ReactiveStreamCommands.GroupCommand to create, destroy,... groups.

Parameters:

command - the ReactiveStreamCommands.GroupCommand to run.

Returns:

the Mono emitting the command result.

xGroup

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.GroupCommand,String>> xGroup(org.reactivestreams.Publisher<ReactiveStreamCommands.GroupCommand> commands)

Execute the given ReactiveStreamCommands.GroupCommand to create, destroy,... groups.

Parameters:

commands -

Returns:

Flux emitting the results of the ReactiveStreamCommands.GroupCommand one by one.

xReadGroup

default reactor.core.publisher.Flux<ByteBufferRecord> xReadGroup(Consumer consumer,
 StreamOffset<ByteBuffer>... streams)

Read records from one or more StreamOffsets using a consumer group.

Parameters:

consumer - consumer/group.

streams - the streams to read from.

Returns:

Flux emitting the members of the stream

See Also:

• Redis Documentation: XREADGROUP

xReadGroup

default reactor.core.publisher.Flux<ByteBufferRecord> xReadGroup(Consumer consumer,
 StreamReadOptions readOptions,
 StreamOffset<ByteBuffer>... streams)

Read records from one or more StreamOffsets using a consumer group.

Parameters:

consumer - consumer/group.

readOptions - read arguments.

streams - the streams to read from.

Returns:

Flux emitting the members of the stream.

See Also:

• Redis Documentation: XREADGROUP

xRevRange

default reactor.core.publisher.Flux<ByteBufferRecord> xRevRange(ByteBuffer key,
 org.springframework.data.domain.Range<String> range)

Read records from a stream within a specific Range in reverse order.

Parameters:

key - the stream key.

range - must not be null.

Returns:

Flux emitting the members of the stream in reverse.

See Also:

• Redis Documentation: XREVRANGE

xRevRange

default reactor.core.publisher.Flux<ByteBufferRecord> xRevRange(ByteBuffer key,
 org.springframework.data.domain.Range<String> range,
 Limit limit)

Read records from a stream within a specific Range applying a Limit in reverse order.

Parameters:

key - the stream key.

range - must not be null.

limit - must not be null.

Returns:

Flux emitting the members of the stream in reverse.

See Also:

• Redis Documentation: XREVRANGE

xRevRange

reactor.core.publisher.Flux<ReactiveRedisConnection.CommandResponse<ReactiveStreamCommands.RangeCommand,reactor.core.publisher.Flux<ByteBufferRecord>>> xRevRange(org.reactivestreams.Publisher<ReactiveStreamCommands.RangeCommand> commands)

Read records from a stream within a specific Range applying a Limit in reverse order.

Parameters:

commands - must not be null.

Returns:

Flux emitting the members of the stream in reverse.

See Also:

• Redis Documentation: XREVRANGE

xTrim

default reactor.core.publisher.Mono<Long> xTrim(ByteBuffer key,
 long count)

Trims the stream to count elements.

Parameters:

key - the stream key.

count - length of the stream.

Returns:

Mono emitting the number of removed entries.

See Also:

• Redis Documentation: XTRIM

xTrim

default reactor.core.publisher.Mono<Long> xTrim(ByteBuffer key,
 long count,
 boolean approximateTrimming)

Trims the stream to count elements.

Parameters:

key - the stream key.

count - length of the stream.

approximateTrimming - the trimming must be performed in a approximated way in order to maximize performances.

Returns:

Mono emitting the number of removed entries.

Since:

2.4

See Also:

• Redis Documentation: XTRIM

xTrim

reactor.core.publisher.Flux<ReactiveRedisConnection.NumericResponse<ReactiveRedisConnection.KeyCommand,Long>> xTrim(org.reactivestreams.Publisher<ReactiveStreamCommands.TrimCommand> commands)

Trims the stream to count elements.

Parameters:

commands - must not be null.

Returns:

Flux emitting the number of removed entries per ReactiveStreamCommands.TrimCommand.

See Also:

• Redis Documentation: XTRIM