public static class ReactiveStreamCommands.AcknowledgeCommand extends ReactiveRedisConnection.KeyCommand
XACK
command parameters.Modifier and Type | Method and Description |
---|---|
ReactiveStreamCommands.AcknowledgeCommand |
forRecords(RecordId... recordIds)
Applies the recordIds.
|
ReactiveStreamCommands.AcknowledgeCommand |
forRecords(String... recordIds)
Applies the recordIds.
|
String |
getGroup() |
List<RecordId> |
getRecordIds() |
ReactiveStreamCommands.AcknowledgeCommand |
inGroup(String group)
Applies the group.
|
static ReactiveStreamCommands.AcknowledgeCommand |
stream(ByteBuffer key)
Creates a new
ReactiveStreamCommands.AcknowledgeCommand given a key . |
getKey
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getName
public static ReactiveStreamCommands.AcknowledgeCommand stream(ByteBuffer key)
ReactiveStreamCommands.AcknowledgeCommand
given a key
.key
- must not be null.ReactiveStreamCommands.AcknowledgeCommand
for key
.public ReactiveStreamCommands.AcknowledgeCommand forRecords(String... recordIds)
recordIds
- must not be null.ReactiveStreamCommands.AcknowledgeCommand
with recordIds applied.public ReactiveStreamCommands.AcknowledgeCommand forRecords(RecordId... recordIds)
recordIds
- must not be null.ReactiveStreamCommands.AcknowledgeCommand
with recordIds applied.public ReactiveStreamCommands.AcknowledgeCommand inGroup(String group)
group
- must not be null.ReactiveStreamCommands.AcknowledgeCommand
with group applied.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.