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
-
Nested Class Summary
Modifier and TypeClassDescriptionstatic enum
-
Constructor Summary
ConstructorDescriptionGroupCommand
(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 TypeMethodDescriptionat
(ReadOffset offset) createGroup
(String group) deleteConsumer
(String consumerName) deleteConsumer
(Consumer consumer) destroyGroup
(String group) forStream
(ByteBuffer key) boolean
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 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
-
destroyGroup
-
deleteConsumer
-
deleteConsumer
-
makeStream
-
at
-
forStream
-
fromGroup
-
isMkStream
public boolean isMkStream() -
getReadOffset
-
getGroupName
-
getConsumerName
-
getAction
-