public static class ReactiveStreamCommands.GroupCommand extends ReactiveRedisConnection.KeyCommand
Modifier and Type | Class and Description |
---|---|
static class |
ReactiveStreamCommands.GroupCommand.GroupCommandAction |
Constructor and Description |
---|
GroupCommand(ByteBuffer key,
ReactiveStreamCommands.GroupCommand.GroupCommandAction action,
String groupName,
String consumerName,
ReadOffset offset) |
Modifier and Type | Method and Description |
---|---|
ReactiveStreamCommands.GroupCommand |
at(ReadOffset offset) |
static ReactiveStreamCommands.GroupCommand |
createGroup(String group) |
static ReactiveStreamCommands.GroupCommand |
deleteConsumer(Consumer consumer) |
static ReactiveStreamCommands.GroupCommand |
deleteConsumer(String consumerName) |
static ReactiveStreamCommands.GroupCommand |
destroyGroup(String group) |
ReactiveStreamCommands.GroupCommand |
forStream(ByteBuffer key) |
ReactiveStreamCommands.GroupCommand |
fromGroup(String groupName) |
ReactiveStreamCommands.GroupCommand.GroupCommandAction |
getAction() |
String |
getConsumerName() |
String |
getGroupName() |
ReadOffset |
getReadOffset() |
getKey
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getName
public GroupCommand(@Nullable ByteBuffer key, ReactiveStreamCommands.GroupCommand.GroupCommandAction action, @Nullable String groupName, @Nullable String consumerName, @Nullable ReadOffset offset)
public static ReactiveStreamCommands.GroupCommand createGroup(String group)
public static ReactiveStreamCommands.GroupCommand destroyGroup(String group)
public static ReactiveStreamCommands.GroupCommand deleteConsumer(String consumerName)
public static ReactiveStreamCommands.GroupCommand deleteConsumer(Consumer consumer)
public ReactiveStreamCommands.GroupCommand at(ReadOffset offset)
public ReactiveStreamCommands.GroupCommand forStream(ByteBuffer key)
public ReactiveStreamCommands.GroupCommand fromGroup(String groupName)
@Nullable public ReadOffset getReadOffset()
public ReactiveStreamCommands.GroupCommand.GroupCommandAction getAction()
Copyright © 2011–2020 Pivotal Software, Inc.. All rights reserved.