Class ReactiveStreamCommands.AddStreamRecord
java.lang.Object
org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand
org.springframework.data.redis.connection.ReactiveStreamCommands.AddStreamRecord
- All Implemented Interfaces:
ReactiveRedisConnection.Command
- Enclosing interface:
- ReactiveStreamCommands
public static class ReactiveStreamCommands.AddStreamRecord
extends ReactiveRedisConnection.KeyCommand
XADD
command parameters.- See Also:
-
Method Summary
Modifier and TypeMethodDescriptionbody
(Map<ByteBuffer, ByteBuffer> body) Creates a newReactiveStreamCommands.AddStreamRecord
givenbody
.getBody()
Limit the size of the stream to the given maximum number of elements.boolean
boolean
Disable creation of stream if it does not already exist.makeNoStream
(boolean makeNoStream) Disable creation of stream if it does not already exist.maxlen
(long maxlen) Limit the size of the stream to the given maximum number of elements.of
(ByteBufferRecord record) Creates a newReactiveStreamCommands.AddStreamRecord
givenbody
.to
(ByteBuffer key) Applies the Geo set key.Methods inherited from class org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand
getKey
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.springframework.data.redis.connection.ReactiveRedisConnection.Command
getName
-
Method Details
-
of
Creates a newReactiveStreamCommands.AddStreamRecord
givenbody
.- Parameters:
record
- must not be null.- Returns:
- a new
ReactiveStreamCommands.AddStreamRecord
.
-
body
Creates a newReactiveStreamCommands.AddStreamRecord
givenbody
.- Parameters:
body
- must not be null.- Returns:
- a new
ReactiveStreamCommands.AddStreamRecord
forMap
.
-
to
Applies the Geo set key. Constructs a new command instance with all previously configured properties.- Parameters:
key
- must not be null.- Returns:
- a new
ReactiveGeoCommands.GeoAddCommand
with key applied.
-
maxlen
Limit the size of the stream to the given maximum number of elements.- Returns:
- new instance of
ReactiveStreamCommands.AddStreamRecord
.
-
makeNoStream
Disable creation of stream if it does not already exist.- Returns:
- new instance of
ReactiveStreamCommands.AddStreamRecord
. - Since:
- 2.6
-
makeNoStream
Disable creation of stream if it does not already exist.- Parameters:
makeNoStream
-true
to not create a stream if it does not already exist.- Returns:
- new instance of
ReactiveStreamCommands.AddStreamRecord
. - Since:
- 2.6
-
getBody
- Returns:
- the actual
Record.getValue()
-
getRecord
-
getMaxlen
Limit the size of the stream to the given maximum number of elements.- Returns:
- can be null.
- Since:
- 2.3
-
hasMaxlen
public boolean hasMaxlen()- Returns:
- true if MAXLEN is set.
- Since:
- 2.3
-
isNoMkStream
public boolean isNoMkStream()- Returns:
- true if NOMKSTREAM is set.
- Since:
- 2.6
-