diff --git a/daemon/redis.c b/daemon/redis.c index 4c7177435..11d10ddcc 100644 --- a/daemon/redis.c +++ b/daemon/redis.c @@ -557,6 +557,13 @@ static int redis_notify(void) { return -1; } + if (rtpe_redis_notify->auth) { + if (redisAsyncCommand(rtpe_redis_notify_async_context, on_redis_notification, NULL, "AUTH %s", rtpe_redis_notify->auth) != REDIS_OK) { + rlog(LOG_ERROR, "Fail redisAsyncCommand on AUTH"); + return -1; + } + } + // subscribe to the values in the configured keyspaces rwlock_lock_r(&rtpe_config.config_lock); for (l = rtpe_config.redis_subscribed_keyspaces.head; l; l = l->next) {