Attachment 665644 Details for Bug 888435 – Patch to add a unit test reproducer

[patch] Patch to add a unit test reproducer

bz888435-reproducer.patch (text/plain), 1.96 KB, created by Jason Dillaman on 2012-12-18 17:24:04 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: Jason Dillaman

Created: 2012-12-18 17:24:04 UTC

Size: 1.96 KB

patch

obsolete

>diff --git a/qpid/cpp/src/tests/ha_tests.py b/qpid/cpp/src/tests/ha_tests.py
>index 7c28e0b..b7840a3 100755
>--- a/qpid/cpp/src/tests/ha_tests.py
>+++ b/qpid/cpp/src/tests/ha_tests.py
>@@ -20,7 +20,8 @@
> 
> import os, signal, sys, time, imp, re, subprocess, glob, random, logging, shutil, math, unittest, random
> import traceback
>-from qpid.messaging import Message, NotFound, ConnectionError, ReceiverError, Connection, Timeout, Disposition, REJECTED, Empty
>+from qpid import *
>+from qpid.messaging import Message, NotFound, ConnectionError, ReceiverError, SessionError, Connection, Timeout, Disposition, REJECTED, Empty
> from qpid.datatypes import uuid4
> from brokertest import *
> from ha_test import *
>@@ -849,6 +850,25 @@ acl deny all all
>         cluster[2].wait_address("xx")
>         self.assertEqual(cluster[2].agent().getExchange("xx").values["bindingCount"], 0)
> 
>+    def test_redeclare_exchange(self):
>+        """Ensure that re-declaring an exchange is an HA no-op"""
>+        cluster = HaCluster(self, 2)
>+        ps = cluster[0].connect().session()
>+        ps.sender("ex1;{create:always,node:{type:topic,x-declare:{arguments:{'qpid.replicate':all}, type:'fanout'}}}")
>+        ps.sender("ex2;{create:always,node:{type:topic,x-declare:{arguments:{'qpid.replicate':all}, type:'fanout', alternate-exchange:'ex1'}}}")
>+        cluster[1].wait_backup("ex1")
>+        cluster[1].wait_backup("ex2")
>+
>+        # Due to bz886656, we need to delete ex2 as a workaround to "set" the
>+        # alt-exchange use count on ex1.
>+        ps.sender("ex2;{delete:always,node:{type:topic}}").close()
>+
>+        # Use old API to re-declare the exchange
>+        old_conn = cluster[0].connect_old()
>+        old_sess = old_conn.session(str(qpid.datatypes.uuid4()))
>+        old_sess.exchange_declare(exchange='ex1', type='fanout')
>+        cluster[1].wait_backup("ex1")
>+
> def fairshare(msgs, limit, levels):
>     """
>     Generator to return prioritised messages in expected order for a given fairshare limit

Actions: View | Diff

Attachments on bug 888435: 665644 | 827435