diff --git a/src/sentinel.c b/src/sentinel.c index a32854344..a96375a79 100644 --- a/src/sentinel.c +++ b/src/sentinel.c @@ -574,7 +574,7 @@ void sentinelGenerateInitialMonitorEvents(void) { di = dictGetIterator(sentinel.masters); while((de = dictNext(di)) != NULL) { sentinelRedisInstance *ri = dictGetVal(de); - sentinelEvent(REDIS_WARNING,"+monitor",ri,"%@"); + sentinelEvent(REDIS_WARNING,"+monitor",ri,"%@ quorum %d",ri->quorum); } dictReleaseIterator(di); } @@ -2558,7 +2558,7 @@ void sentinelCommand(redisClient *c) { } } else { sentinelFlushConfig(); - sentinelEvent(REDIS_WARNING,"+monitor",ri,"%@"); + sentinelEvent(REDIS_WARNING,"+monitor",ri,"%@ quorum %d",ri->quorum); addReply(c,shared.ok); } } else if (!strcasecmp(c->argv[1]->ptr,"remove")) {