Commit 1569af1f authored by antirez's avatar antirez
Browse files

Sentinel: receive Pub/Sub messages from slaves.

parent dfa5f8b7
...@@ -1334,7 +1334,7 @@ void sentinelReconnectInstance(sentinelRedisInstance *ri) { ...@@ -1334,7 +1334,7 @@ void sentinelReconnectInstance(sentinelRedisInstance *ri) {
} }
} }
/* Pub / Sub */ /* Pub / Sub */
if ((ri->flags & SRI_MASTER) && ri->pc == NULL) { if ((ri->flags & (SRI_MASTER|SRI_SLAVE)) && ri->pc == NULL) {
ri->pc = redisAsyncConnect(ri->addr->ip,ri->addr->port); ri->pc = redisAsyncConnect(ri->addr->ip,ri->addr->port);
if (ri->pc->err) { if (ri->pc->err) {
sentinelEvent(REDIS_DEBUG,"-pubsub-link-reconnection",ri,"%@ #%s", sentinelEvent(REDIS_DEBUG,"-pubsub-link-reconnection",ri,"%@ #%s",
......
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