summaryrefslogtreecommitdiff
path: root/qpid/cpp/src/tests/ha_test.py
diff options
context:
space:
mode:
authorAlan Conway <aconway@apache.org>2014-04-24 18:59:03 +0000
committerAlan Conway <aconway@apache.org>2014-04-24 18:59:03 +0000
commite8f4b182c6a6b4df51a4853d21319e624b1203b7 (patch)
tree9c68e5d8fa1ae0200f59b20c8adb5281a2e9b44e /qpid/cpp/src/tests/ha_test.py
parent1d3b4560f8a7f212976b536376a976b3b41f489b (diff)
downloadqpid-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-xqpid/cpp/src/tests/ha_test.py8
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)