xack(
name: KeyT, // name of the stream.
groupname: GroupT, // name of the consumer group.
*ids: StreamIdT // message ids to acknowledge.
) → ResponseT
XACK(
key: RedisArgument,
group: RedisArgument,
id: RedisVariadicArgument
) → Any
xack(
key: byte[],
group: byte[],
ids: byte[]...
) → long
xack(
key: String,
group: String,
ids: StreamEntryID...
) → long
xack(
key: String,
group: String,
ids: StreamEntryID...
) → long
xack(
key: K, // the stream key.
group: K, // name of the consumer group.
messageIds: String... // message Id's to acknowledge.
) → Long // simple-reply the lenght of acknowledged messages.
xack(
key: K, // the stream key.
group: K, // name of the consumer group.
messageIds: String... // message Id's to acknowledge.
) → RedisFuture<Long> // simple-reply the lenght of acknowledged messages.
xack(
key: K, // the stream key.
group: K, // name of the consumer group.
messageIds: String... // message Id's to acknowledge.
) → Mono<Long> // simple-reply the lenght of acknowledged messages.
XAck(
ctx: context.Context,
stream: Any,
group: string,
ids: ...string
) → *IntCmd
StreamAcknowledge(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group that received the message.
messageId: RedisValue,
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages acknowledged.
StreamAcknowledge(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group that received the message.
messageIds: RedisValue[], // The IDs of the messages to acknowledge.
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages acknowledged.
StreamAcknowledge(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group that received the message.
messageId: RedisValue,
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages acknowledged.
StreamAcknowledge(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group that received the message.
messageIds: RedisValue[], // The IDs of the messages to acknowledge.
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages acknowledged.
StreamAcknowledge(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group that received the message.
messageId: RedisValue,
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages acknowledged.
StreamAcknowledge(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group that received the message.
messageIds: RedisValue[], // The IDs of the messages to acknowledge.
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages acknowledged.
StreamAcknowledge(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group that received the message.
messageId: RedisValue,
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages acknowledged.
StreamAcknowledge(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group that received the message.
messageIds: RedisValue[], // The IDs of the messages to acknowledge.
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages acknowledged.
xack(
$key: string,
$group: string,
$id: string ...
) → int
xack(
key: K,
group: G,
ids: &'a [I]
) → (usize)
xack(
key: K,
group: G,
ids: &'a [I]
) → (usize)
