public static class ReactiveStreamCommands.AddStreamRecord extends ReactiveRedisConnection.KeyCommand
XADD
command parameters.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 ReactiveStreamCommands.AddStreamRecord makeNoStream()
ReactiveStreamCommands.AddStreamRecord
.public ReactiveStreamCommands.AddStreamRecord makeNoStream(boolean makeNoStream)
makeNoStream
- true
to not create a stream if it does not already exist.ReactiveStreamCommands.AddStreamRecord
.public Map<ByteBuffer,ByteBuffer> getBody()
Record.getValue()
public ByteBufferRecord getRecord()
@Nullable public Long getMaxlen()
public boolean hasMaxlen()
public boolean isNoMkStream()
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.