xgroup_delconsumer(
name: KeyT,
groupname: GroupT,
consumername: ConsumerT
) → ResponseT
XGROUP_DELCONSUMER(
key: RedisArgument,
group: RedisArgument,
consumer: RedisArgument
) → Any
xgroupDelConsumer(
key: byte[],
groupName: byte[],
consumerName: byte[]
) → long
xgroupDelConsumer(
key: String,
groupName: String,
consumerName: String
) → long
xgroupDelConsumer(
key: String,
groupName: String,
consumerName: String
) → long
xgroupDelconsumer(
key: K, // the stream key.
consumer: Consumer<K> // consumer identified by group name and consumer key.
) → Long // Long integer-reply number of pending messages.
xgroupDelconsumer(
key: K, // the stream key.
consumer: Consumer<K> // consumer identified by group name and consumer key.
) → RedisFuture<Long> // Long integer-reply number of pending messages.
xgroupDelconsumer(
key: K, // the stream key.
consumer: Consumer<K> // consumer identified by group name and consumer key.
) → Mono<Long> // Long integer-reply number of pending messages.
XGroupDelConsumer(
ctx: context.Context,
stream: Any,
group: Any,
consumer: string
) → *IntCmd
StreamDeleteConsumer(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group.
consumerName: RedisValue, // The name of the consumer.
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages that were pending for the deleted consumer.
StreamDeleteConsumer(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group.
consumerName: RedisValue, // The name of the consumer.
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages that were pending for the deleted consumer.
StreamDeleteConsumer(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group.
consumerName: RedisValue, // The name of the consumer.
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages that were pending for the deleted consumer.
StreamDeleteConsumer(
key: RedisKey, // The key of the stream.
groupName: RedisValue, // The name of the consumer group.
consumerName: RedisValue, // The name of the consumer.
flags: CommandFlags // The flags to use for this operation.
) → long // The number of messages that were pending for the deleted consumer.
delConsumer(
$key: string,
$group: string,
$consumer: string
) → int
xgroup_delconsumer(
key: K,
group: G,
consumer: C
) → usize
xgroup_delconsumer(
key: K,
group: G,
consumer: C
) → usize
