diff --git a/src/sentinel.c b/src/sentinel.c index 2de5942168ce2d46bfd4165fa1a125ca6f921930..250ef61a0b3e6eda41b8044946117abc2cde3f1b 100644 --- a/src/sentinel.c +++ b/src/sentinel.c @@ -1336,7 +1336,7 @@ void sentinelReconnectInstance(sentinelRedisInstance *ri) { } } /* 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); if (ri->pc->err) { sentinelEvent(REDIS_DEBUG,"-pubsub-link-reconnection",ri,"%@ #%s",