diff --git a/src/t_stream.c b/src/t_stream.c index 5891b774..ad47941a 100644 --- a/src/t_stream.c +++ b/src/t_stream.c @@ -2019,6 +2019,9 @@ void xdelCommand(client *c) { streamParseIDOrReply(c,c->argv[j],&id,0); /* Retval already checked. */ 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); } /* XINFO CONSUMERS key group