[jbosscache-commits] JBoss Cache SVN: r7532 - core/trunk/src/test/java/org/jboss/cache/util/internals/replicationlisteners.

[jbosscache-commits at lists.jboss.org]

Author: mircea.markus
Date: 2009-01-20 10:27:34 -0500 (Tue, 20 Jan 2009)
New Revision: 7532

Modified:
   core/trunk/src/test/java/org/jboss/cache/util/internals/replicationlisteners/ReplicationListener.java
Log:
refuse to wait for caches that are not started

Modified: core/trunk/src/test/java/org/jboss/cache/util/internals/replicationlisteners/ReplicationListener.java
===================================================================
--- core/trunk/src/test/java/org/jboss/cache/util/internals/replicationlisteners/ReplicationListener.java	2009-01-20 15:21:32 UTC (rev 7531)
+++ core/trunk/src/test/java/org/jboss/cache/util/internals/replicationlisteners/ReplicationListener.java	2009-01-20 15:27:34 UTC (rev 7532)
@@ -2,6 +2,8 @@
 
 import org.jboss.cache.Cache;
 import org.jboss.cache.RPCManager;
+import org.jboss.cache.CacheSPI;
+import org.jboss.cache.CacheStatus;
 import org.jboss.cache.commands.ReplicableCommand;
 import org.jboss.cache.commands.remote.*;
 import org.jboss.cache.commands.tx.PrepareCommand;
@@ -176,6 +178,11 @@
     */
    public void waitForReplicationToOccur(long timeoutMillis)
    {
+      CacheStatus state = ((CacheSPI) cache).getComponentRegistry().getState();
+      if (!state.equals(CacheStatus.STARTED))
+      {
+         throw new IllegalStateException("Cannot invoke on an cache that is not started: current cache status is " + state);
+      }
 //      log("enter... ReplicationListener.waitForReplicationToOccur");
       waitForReplicationToOccur(timeoutMillis, TimeUnit.MILLISECONDS);
 //      log("exit... ReplicationListener.waitForReplicationToOccur");