diff options
| author | Alan Conway <aconway@apache.org> | 2014-04-24 18:59:03 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2014-04-24 18:59:03 +0000 |
| commit | e8f4b182c6a6b4df51a4853d21319e624b1203b7 (patch) | |
| tree | 9c68e5d8fa1ae0200f59b20c8adb5281a2e9b44e /qpid/cpp/src/tests/ha_test.py | |
| parent | 1d3b4560f8a7f212976b536376a976b3b41f489b (diff) | |
| download | qpid-python-e8f4b182c6a6b4df51a4853d21319e624b1203b7.tar.gz | |
NO-JIRA: HA minor cleanup of qpid-ha tool
- Remove some dead code.
- Removed "set" command - not ready for production. All settings in qpidd.conf.
- Removed related tests in ha_tests
- Improved help on promote command.
- Made option group for common broker connection options.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1589834 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/cpp/src/tests/ha_test.py')
| -rwxr-xr-x | qpid/cpp/src/tests/ha_test.py | 8 |
1 files changed, 0 insertions, 8 deletions
diff --git a/qpid/cpp/src/tests/ha_test.py b/qpid/cpp/src/tests/ha_test.py index 132892cb2f..fe1894ecc8 100755 --- a/qpid/cpp/src/tests/ha_test.py +++ b/qpid/cpp/src/tests/ha_test.py @@ -177,8 +177,6 @@ acl allow all all raise Exception("Error in qpid_ha -b %s %s: %s"%(url, args,e)) def promote(self): self.ready(); self.qpid_ha(["promote"]) - def set_public_url(self, url): self.qpid_ha(["set", "--public-url", url]) - def set_brokers_url(self, url): self.qpid_ha(["set", "--brokers-url", url]); def replicate(self, from_broker, queue): self.qpid_ha(["replicate", from_broker, queue]) @property def agent(self): @@ -343,7 +341,6 @@ class HaCluster(object): if i == len(self._ports): # Adding new broker after cluster init self._ports.append(HaPort(self.test)) self._set_url() - self._update_urls() b = self._ha_broker(i, self.next_name()) self._brokers.append(b) return b @@ -351,11 +348,6 @@ class HaCluster(object): def _set_url(self): self.url = ",".join("127.0.0.1:%s"%(p.port) for p in self._ports) - def _update_urls(self): - for b in self: - b.set_brokers_url(self.url) - b.set_public_url(self.url) - def connect(self, i, **kwargs): """Connect with reconnect_urls""" return self[i].connect(reconnect=True, reconnect_urls=self.url.split(","), **kwargs) |
