Streams: rewrite id in XSTREAM CREATE *

This commit is contained in:
zhaozhao.zz
2018-10-09 16:22:30 +08:00
committed by antirez
parent f4b4db1387
commit a3fb28edce

View File

@ -1808,6 +1808,10 @@ NULL
s->last_id = id;
dbAdd(c->db,c->argv[2],o);
robj *idarg = createObjectFromStreamID(&id);
rewriteClientCommandArgument(c,3,idarg);
decrRefCount(idarg);
addReply(c,shared.ok);
server.dirty++;
notifyKeyspaceEvent(NOTIFY_STREAM,"xstream-create",