Class ReactiveStreamCommands.AcknowledgeCommand
java.lang.Object
org.springframework.data.redis.connection.ReactiveRedisConnection.KeyCommand
org.springframework.data.redis.connection.ReactiveStreamCommands.AcknowledgeCommand
- All Implemented Interfaces:
ReactiveRedisConnection.Command
- Enclosing interface:
- ReactiveStreamCommands
public static class ReactiveStreamCommands.AcknowledgeCommand
extends ReactiveRedisConnection.KeyCommand
XACK
command parameters.- See Also:
-
Method Summary
Modifier and TypeMethodDescriptionforRecords
(String... recordIds) Applies the recordIds.forRecords
(RecordId... recordIds) Applies the recordIds.getGroup()
Applies the group.stream
(ByteBuffer key) Creates a newReactiveStreamCommands.AcknowledgeCommand
given akey
.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
-
Method Details
-
stream
Creates a newReactiveStreamCommands.AcknowledgeCommand
given akey
.- Parameters:
key
- must not be null.- Returns:
- a new
ReactiveStreamCommands.AcknowledgeCommand
forkey
.
-
forRecords
Applies the recordIds. Constructs a new command instance with all previously configured properties.- Parameters:
recordIds
- must not be null.- Returns:
- a new
ReactiveStreamCommands.AcknowledgeCommand
with recordIds applied.
-
forRecords
Applies the recordIds. Constructs a new command instance with all previously configured properties.- Parameters:
recordIds
- must not be null.- Returns:
- a new
ReactiveStreamCommands.AcknowledgeCommand
with recordIds applied.
-
inGroup
Applies the group. Constructs a new command instance with all previously configured properties.- Parameters:
group
- must not be null.- Returns:
- a new
ReactiveStreamCommands.AcknowledgeCommand
with group applied.
-
getGroup
-
getRecordIds
-