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");