Commit 19ae8094 authored by antirez's avatar antirez
Browse files

Streams: XADD, handle signaling of write in different ways.

parent aba76320
...@@ -2019,6 +2019,9 @@ void xdelCommand(client *c) { ...@@ -2019,6 +2019,9 @@ void xdelCommand(client *c) {
streamParseIDOrReply(c,c->argv[j],&id,0); /* Retval already checked. */ streamParseIDOrReply(c,c->argv[j],&id,0); /* Retval already checked. */
deleted += streamDeleteItem(s,&id); deleted += streamDeleteItem(s,&id);
} }
signalModifiedKey(c->db,c->argv[1]);
notifyKeyspaceEvent(NOTIFY_STREAM,"xdel",c->argv[1],c->db->id);
server.dirty += deleted;
addReplyLongLong(c,deleted); addReplyLongLong(c,deleted);
} }
/* XINFO CONSUMERS key group /* XINFO CONSUMERS key group
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment