public static class ReactiveStreamCommands.AddStreamRecord extends ReactiveRedisConnection.KeyCommand
XADD
command parameters.Modifier and Type | Method and Description |
---|---|
static ReactiveStreamCommands.AddStreamRecord |
body(Map<ByteBuffer,ByteBuffer> body)
Creates a new
ReactiveStreamCommands.AddStreamRecord given body . |
Map<ByteBuffer,ByteBuffer> |
getBody() |
Long |
getMaxlen()
Limit the size of the stream to the given maximum number of elements.
|
ByteBufferRecord |
getRecord() |
boolean |
hasMaxlen() |
ReactiveStreamCommands.AddStreamRecord |
maxlen(long maxlen)
Limit the size of the stream to the given maximum number of elements.
|
static ReactiveStreamCommands.AddStreamRecord |
of(ByteBufferRecord record)
Creates a new
ReactiveStreamCommands.AddStreamRecord given body . |
ReactiveStreamCommands.AddStreamRecord |
to(ByteBuffer key)
Applies the Geo set key.
|
getKey
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getName
public static ReactiveStreamCommands.AddStreamRecord of(ByteBufferRecord record)
ReactiveStreamCommands.AddStreamRecord
given body
.record
- must not be null.ReactiveStreamCommands.AddStreamRecord
.public static ReactiveStreamCommands.AddStreamRecord body(Map<ByteBuffer,ByteBuffer> body)
ReactiveStreamCommands.AddStreamRecord
given body
.body
- must not be null.ReactiveStreamCommands.AddStreamRecord
for Map
.public ReactiveStreamCommands.AddStreamRecord to(ByteBuffer key)
key
- must not be null.ReactiveGeoCommands.GeoAddCommand
with key applied.public ReactiveStreamCommands.AddStreamRecord maxlen(long maxlen)
ReactiveStreamCommands.AddStreamRecord
.public Map<ByteBuffer,ByteBuffer> getBody()
Record.getValue()
public ByteBufferRecord getRecord()
@Nullable public Long getMaxlen()
public boolean hasMaxlen()
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.