diff --git a/controller/PostgreSQL.cpp b/controller/PostgreSQL.cpp index 31d5b911..e3d513a0 100644 --- a/controller/PostgreSQL.cpp +++ b/controller/PostgreSQL.cpp @@ -761,6 +761,11 @@ void PostgreSQL::_membersWatcher_Redis() { fprintf(stderr, "json parse error in networkWatcher_Redis\n"); } } + if (_rc->clusterMode) { + _cluster->xdel(key, id); + } else { + _redis->xdel(key, id); + } } } } @@ -873,6 +878,11 @@ void PostgreSQL::_networksWatcher_Redis() { fprintf(stderr, "json parse error in networkWatcher_Redis\n"); } } + if (_rc->clusterMode) { + _cluster->xdel(key, id); + } else { + _redis->xdel(key, id); + } } } }