mirror of
https://github.com/fluencelabs/redis
synced 2025-03-19 17:10:50 +00:00
CG: More specific duplicated group error.
This commit is contained in:
parent
9f60a6bcee
commit
c9d86c2b16
@ -1391,7 +1391,8 @@ NULL
|
|||||||
if (cg) {
|
if (cg) {
|
||||||
addReply(c,shared.ok);
|
addReply(c,shared.ok);
|
||||||
} else {
|
} else {
|
||||||
addReplyError(c,"Consumer Group name already exists");
|
addReplySds(c,
|
||||||
|
sdsnew("-BUSYGROUP Consumer Group name already exists\r\n"));
|
||||||
}
|
}
|
||||||
} else if (!strcasecmp(opt,"SETID") && c->argc == 5) {
|
} else if (!strcasecmp(opt,"SETID") && c->argc == 5) {
|
||||||
} else if (!strcasecmp(opt,"DELGROUP") && c->argc == 4) {
|
} else if (!strcasecmp(opt,"DELGROUP") && c->argc == 4) {
|
||||||
|
11
tests/unit/type/stream-cgroups.tcl
Normal file
11
tests/unit/type/stream-cgroups.tcl
Normal file
@ -0,0 +1,11 @@
|
|||||||
|
start_server {
|
||||||
|
tags {"stream"}
|
||||||
|
} {
|
||||||
|
test {XGROUP CREATE: creation and duplicate group name detection} {
|
||||||
|
r DEL mystream
|
||||||
|
r XADD mystream * foo bar
|
||||||
|
r XGROUP CREATE mystream mygroup $
|
||||||
|
catch {r XGROUP CREATE mystream mygroup $} err
|
||||||
|
set err
|
||||||
|
} {BUSYGROUP*}
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user