diff options
| author | ozamiatin <ozamiatin@mirantis.com> | 2016-02-25 12:56:27 +0200 |
|---|---|---|
| committer | ozamiatin <ozamiatin@mirantis.com> | 2016-02-25 13:01:26 +0200 |
| commit | 02135bc1f46fc80d4fa3cdc505136af98bb1e4fd (patch) | |
| tree | 28d4003fceebf529b5cd89dfc7f7f24d6cc793e9 | |
| parent | a17e42d5cf11ac4e176925cc5fb30db5e2034d0c (diff) | |
| download | oslo-messaging-02135bc1f46fc80d4fa3cdc505136af98bb1e4fd.tar.gz | |
[zmq] Matchmaker redis set instead of list
No need to check element before push.
Change-Id: Ic4b5ff829d0d94a35aaab1af8ff6991a0b5cebe6
Related-to: I25d623eb4bb0a827daa8a316a0ddcb4a473f8694
| -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) |