diff options
| author | Alan Conway <aconway@apache.org> | 2012-10-02 18:41:41 +0000 |
|---|---|---|
| committer | Alan Conway <aconway@apache.org> | 2012-10-02 18:41:41 +0000 |
| commit | b45b6daf6121e3f069de938439e1e37ff0cf7cc1 (patch) | |
| tree | 90e8934452fa96d1b473dc73fdfca36f0d155490 /qpid/cpp/src/tests/ha_test.py | |
| parent | 91dfa1fd49a50a3dae9d12ae5f6b08c711428683 (diff) | |
| download | qpid-python-b45b6daf6121e3f069de938439e1e37ff0cf7cc1.tar.gz | |
QPID-4285: HA backups continuously disconnect / re-sync after attempting to replicate a deleted queue. (Based on patch by Jason Dillama)
This does not directly tackle the origin of the problem but extends Jasons's patch since
it addresses something we had to fix anyway: "leaking" queues and exchanges. It does 2 things.
1. enabled hideDeletedError on all subscription objects used by HA
This suppress the troublesome exception with a harmless no-op
2. Delete queues/exchanges missing from responses (based on Jasons patch)
Fix the "leak" of queues and exchanges possible when an object replicated
to a backup is deleted from the newn primary before the backup connects.
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1393089 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 | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/qpid/cpp/src/tests/ha_test.py b/qpid/cpp/src/tests/ha_test.py index 2f9d9a1211..79db67e3c8 100755 --- a/qpid/cpp/src/tests/ha_test.py +++ b/qpid/cpp/src/tests/ha_test.py @@ -209,6 +209,7 @@ class HaCluster(object): def start(self, update_urls=True, args=[]): """Start a new broker in the cluster""" b = HaBroker(self.test, name=self.next_name(), **self.kwargs) + b.ready() self._brokers.append(b) if update_urls: self.update_urls() return b @@ -235,6 +236,7 @@ class HaCluster(object): self._brokers[i] = HaBroker( self.test, name=b.name, port=b.port(), brokers_url=self.url, **self.kwargs) + self._brokers[i].ready() def bounce(self, i, promote_next=True): """Stop and restart a broker in a cluster.""" |