Class ReactiveStreamCommands.GroupCommand

java.lang.Object

org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand

org.springframework.data.redis.connection.ReactiveStreamCommands.GroupCommand

All Implemented Interfaces:

ReactiveRedisConnection.Command

Enclosing interface:

ReactiveStreamCommands

public static class ReactiveStreamCommands.GroupCommand
extends ReactiveRedisConnection.KeyCommand

Since:

2.2

Author:

Mark Paluch, Christoph Strobl, Tugdual Grall, Dengliming, Mark John Moreno, jinkshower, Jeonggyu Choi

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ReactiveStreamCommands.GroupCommand.GroupCommandAction

Constructor Summary

Constructors

Constructor	Description
GroupCommand(@Nullable ByteBuffer key, ReactiveStreamCommands.GroupCommand.GroupCommandAction action, @Nullable String groupName, @Nullable String consumerName, @Nullable ReadOffset offset)
GroupCommand(@Nullable ByteBuffer key, ReactiveStreamCommands.GroupCommand.GroupCommandAction action, @Nullable String groupName, @Nullable String consumerName, @Nullable ReadOffset offset, boolean mkStream)

Method Summary

Modifier and Type	Method	Description
ReactiveStreamCommands.GroupCommand	at(ReadOffset offset)
static ReactiveStreamCommands.GroupCommand	createGroup(String group)
static ReactiveStreamCommands.GroupCommand	deleteConsumer(String consumerName)
static ReactiveStreamCommands.GroupCommand	deleteConsumer(Consumer consumer)
static ReactiveStreamCommands.GroupCommand	destroyGroup(String group)
ReactiveStreamCommands.GroupCommand	forStream(ByteBuffer key)
ReactiveStreamCommands.GroupCommand	fromGroup(String groupName)
ReactiveStreamCommands.GroupCommand.GroupCommandAction	getAction()
@Nullable String	getConsumerName()
@Nullable String	getGroupName()
@Nullable ReadOffset	getReadOffset()
boolean	isMkStream()
ReactiveStreamCommands.GroupCommand	makeStream(boolean mkStream)

Methods inherited from class ReactiveRedisConnection.KeyCommand

getKey

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface ReactiveRedisConnection.Command

getName

Constructor Details

GroupCommand

public GroupCommand(@Nullable ByteBuffer key,
 ReactiveStreamCommands.GroupCommand.GroupCommandAction action,
 @Nullable String groupName,
 @Nullable String consumerName,
 @Nullable ReadOffset offset,
 boolean mkStream)

GroupCommand

public GroupCommand(@Nullable ByteBuffer key,
 ReactiveStreamCommands.GroupCommand.GroupCommandAction action,
 @Nullable String groupName,
 @Nullable String consumerName,
 @Nullable ReadOffset offset)

Method Details

createGroup

public static ReactiveStreamCommands.GroupCommand createGroup(String group)

destroyGroup

public static ReactiveStreamCommands.GroupCommand destroyGroup(String group)

deleteConsumer

public static ReactiveStreamCommands.GroupCommand deleteConsumer(String consumerName)

deleteConsumer

public static ReactiveStreamCommands.GroupCommand deleteConsumer(Consumer consumer)

makeStream

public ReactiveStreamCommands.GroupCommand makeStream(boolean mkStream)

at

public ReactiveStreamCommands.GroupCommand at(ReadOffset offset)

forStream

public ReactiveStreamCommands.GroupCommand forStream(ByteBuffer key)

fromGroup

public ReactiveStreamCommands.GroupCommand fromGroup(String groupName)

isMkStream

public boolean isMkStream()

getReadOffset

public @Nullable ReadOffset getReadOffset()

getGroupName

public @Nullable String getGroupName()

getConsumerName

public @Nullable String getConsumerName()

getAction

public ReactiveStreamCommands.GroupCommand.GroupCommandAction getAction()