[hornetq-commits] JBoss hornetq SVN: r11187 - in branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster: util and 1 other directory.

[do-not-reply at jboss.org]

Author: borges
Date: 2011-08-11 13:08:09 -0400 (Thu, 11 Aug 2011)
New Revision: 11187

Added:
   branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ReplicatedLargeMessageWithDelayFailoverTest.java
Modified:
   branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTest.java
   branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/util/BackupSyncDelay.java
Log:
HORNETQ-720 Add test for Replication Sync of LargeMessages

Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTest.java
===================================================================
--- branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTest.java	2011-08-11 16:56:03 UTC (rev 11186)
+++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/FailoverTest.java	2011-08-11 17:08:09 UTC (rev 11187)
@@ -135,7 +135,7 @@
    @Override
    protected void crash(ClientSession... sessions) throws Exception
    {
-      if (backupServer != null)
+      if (backupServer != null && backupServer.isStarted())
       {
          // some tests crash the liveServer before the backupServer is sync'ed
          waitForBackup(sf, 3);

Added: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ReplicatedLargeMessageWithDelayFailoverTest.java
===================================================================
--- branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ReplicatedLargeMessageWithDelayFailoverTest.java	                        (rev 0)
+++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/failover/ReplicatedLargeMessageWithDelayFailoverTest.java	2011-08-11 17:08:09 UTC (rev 11187)
@@ -0,0 +1,26 @@
+package org.hornetq.tests.integration.cluster.failover;
+
+import org.hornetq.api.core.client.ClientSession;
+import org.hornetq.tests.integration.cluster.util.BackupSyncDelay;
+
+public class ReplicatedLargeMessageWithDelayFailoverTest extends ReplicatedLargeMessageFailoverTest
+{
+
+   private BackupSyncDelay syncDelay;
+
+   @Override
+   protected void setUp() throws Exception
+   {
+      startBackupServer = false;
+      super.setUp();
+      syncDelay = new BackupSyncDelay(backupServer, liveServer);
+      backupServer.start();
+   }
+
+   @Override
+   protected void crash(ClientSession... sessions) throws Exception
+   {
+      syncDelay.deliverUpToDateMsg();
+      super.crash(sessions);
+   }
+}

Modified: branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/util/BackupSyncDelay.java
===================================================================
--- branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/util/BackupSyncDelay.java	2011-08-11 16:56:03 UTC (rev 11186)
+++ branches/HORNETQ-720_Replication/tests/integration-tests/src/test/java/org/hornetq/tests/integration/cluster/util/BackupSyncDelay.java	2011-08-11 17:08:09 UTC (rev 11187)
@@ -41,7 +41,8 @@
 
    public void deliverUpToDateMsg()
    {
-      handler.deliver();
+      if (backup.isStarted())
+         handler.deliver();
    }
 
    public BackupSyncDelay(TestableServer backup, TestableServer live)