diff options
| author | Jenkins <jenkins@review.openstack.org> | 2016-02-25 18:05:01 +0000 |
|---|---|---|
| committer | Gerrit Code Review <review@openstack.org> | 2016-02-25 18:05:01 +0000 |
| commit | b2f68cc34faf3bffb3591ae3950db5ef74515b84 (patch) | |
| tree | be0e3f99c25a233dc9d25dcbcad14776ea5dd4ea | |
| parent | d8c7c8f2c039490f13ad0e8a0849956d9c3cddbe (diff) | |
| parent | 02135bc1f46fc80d4fa3cdc505136af98bb1e4fd (diff) | |
| download | oslo-messaging-b2f68cc34faf3bffb3591ae3950db5ef74515b84.tar.gz | |
Merge "[zmq] Matchmaker redis set instead of list"
| -rw-r--r-- | oslo_messaging/_drivers/zmq_driver/matchmaker/matchmaker_redis.py | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/oslo_messaging/_drivers/zmq_driver/matchmaker/matchmaker_redis.py b/oslo_messaging/_drivers/zmq_driver/matchmaker/matchmaker_redis.py index 1ef48ac..0d0ce8b 100644 --- a/oslo_messaging/_drivers/zmq_driver/matchmaker/matchmaker_redis.py +++ b/oslo_messaging/_drivers/zmq_driver/matchmaker/matchmaker_redis.py @@ -131,8 +131,7 @@ class RedisMatchMaker(base.MatchMakerBase): def register_publisher(self, hostname): host_str = ",".join(hostname) - if host_str not in self._get_hosts_by_key(_PUBLISHERS_KEY): - self._redis.sadd(_PUBLISHERS_KEY, host_str) + self._redis.sadd(_PUBLISHERS_KEY, host_str) def unregister_publisher(self, hostname): host_str = ",".join(hostname) |