org.springframework.data.redis.connection

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

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

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

Method Summary

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()
boolean	isMkStream()
ReactiveStreamCommands.GroupCommand	makeStream(boolean mkStream)

Methods inherited from class org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand

getKey

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.data.redis.connection.ReactiveRedisConnection.Command

getName

Constructor Detail

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 Detail

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

@Nullable
public ReadOffset getReadOffset()

getGroupName

@Nullable
public String getGroupName()

getConsumerName

@Nullable
public String getConsumerName()

getAction

public ReactiveStreamCommands.GroupCommand.GroupCommandAction getAction()