Added a failover test case that uses durable subscriptions.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1002448 13f79535-47bb-0310-9956-ffa450edef68

1 files changed, 37 insertions, 1 deletions

diff --git a/java/testkit/testkit.py b/java/testkit/testkit.py
index 4e6ee9b586..5f83156c38 100755
--- a/java/testkit/testkit.py
+++ b/java/testkit/testkit.py
@@ -213,4 +213,40 @@ class SoakTest(JavaClientTest):
 
         self.verify(receiver,sender)
         if error_msg:      
-            raise Exception(error_msg)               
+            raise Exception(error_msg)            
+     
+    def test_failover_with_durablesub(self):
+        cluster = self.cluster(4, expect=EXPECT_EXIT_FAIL)
+        p = cluster[0].port()
+        self.start_error_watcher(broker=cluster[0])
+        receiver = self.popen(self.client(receiver=True,
+                                          ssn_per_con=1,
+                                          port=p,
+                                          jms_durable_sub=True,
+                                          test_name=self.id()),
+                              expect=EXPECT_RUNNING) 
+
+        sender = self.popen(self.client(sender=True,
+                                        ssn_per_con=1,
+                                        port=p,
+                                        test_name=self.id()),
+                              expect=EXPECT_RUNNING) 
+      
+        # grace period for java clients to get the failover properly setup.
+        time.sleep(30) 
+        error_msg=None
+        # Kill original brokers, start new ones.
+        try:
+            for i in range(8):
+                cluster[i].kill()
+                b=cluster.start()
+                self.monitor_clients(broker=b,run_time=30,error_ck_freq=30)
+        except ConnectError, e1:
+            error_msg = "Unable to connect to new cluster node : " + traceback.format_exc(e1)
+
+        except SessionError, e2:
+            error_msg = "Session error while connected to new cluster node : " + traceback.format_exc(e2)
+
+        self.verify(receiver,sender)
+        if error_msg:      
+            raise Exception(error_msg)