Author: manik.surtani(a)jboss.com Date: 2009-02-08 06:21:51 -0500 (Sun, 08 Feb 2009) New Revision: 7663 Removed: core/branches/flat/src/test/java/org/horizon/config/parsing/XmlFileParsingTest.java Log: Expiry stuff Deleted: core/branches/flat/src/test/java/org/horizon/config/parsing/XmlFileParsingTest.java =================================================================== --- core/branches/flat/src/test/java/org/horizon/config/parsing/XmlFileParsingTest.java 2009-02-08 11:20:49 UTC (rev 7662) +++ core/branches/flat/src/test/java/org/horizon/config/parsing/XmlFileParsingTest.java 2009-02-08 11:21:51 UTC (rev 7663) @@ -1,164 +0,0 @@ -package org.horizon.config.parsing; - -import org.horizon.config.Configuration; -import org.horizon.config.GlobalConfiguration; -import org.horizon.lock.IsolationLevel; -import org.testng.annotations.Test; - -import java.io.IOException; -import java.util.Map; - -@Test(groups = "unit") -public class XmlFileParsingTest { - public void testNamedCacheFile() throws IOException { - XmlConfigurationParser parser = new XmlConfigurationParserImpl("configs/named-cache-test.xml"); - - GlobalConfiguration gc = parser.parseGlobalConfiguration(); - - assert gc.getAsyncListenerExecutorFactoryClass().equals("org.horizon.executors.DefaultExecutorFactory"); - assert gc.getAsyncListenerExecutorProperties().getProperty("maxThreads").equals("5"); - assert gc.getAsyncListenerExecutorProperties().getProperty("threadNamePrefix").equals("AsyncListenerThread"); - - assert gc.getAsyncSerializationExecutorFactoryClass().equals("org.horizon.executors.DefaultExecutorFactory"); - assert gc.getAsyncSerializationExecutorProperties().getProperty("maxThreads").equals("25"); - assert gc.getAsyncSerializationExecutorProperties().getProperty("threadNamePrefix").equals("AsyncSerializationThread"); - - assert gc.getEvictionScheduledExecutorFactoryClass().equals("org.horizon.executors.DefaultScheduledExecutorFactory"); - assert gc.getEvictionScheduledExecutorProperties().getProperty("threadNamePrefix").equals("EvictionThread"); - - assert gc.getReplicationQueueScheduledExecutorFactoryClass().equals("org.horizon.executors.DefaultScheduledExecutorFactory"); - assert gc.getReplicationQueueScheduledExecutorProperties().getProperty("threadNamePrefix").equals("ReplicationQueueThread"); - - assert gc.getTransportClass().equals("org.horizon.remoting.transport.jgroups.JGroupsTransport"); - assert gc.getTransportProperties().isEmpty(); - - assert gc.getMarshallerClass().equals("org.horizon.marshall.VersionAwareMarshaller"); - assert gc.getMarshallVersionString().equals("1.0"); - assert gc.getObjectOutputStreamPoolSize() == 100; - assert gc.getObjectInputStreamPoolSize() == 100; - - Configuration defaultConfiguration = parser.parseDefaultConfiguration(); - - assert defaultConfiguration.getLockAcquisitionTimeout() == 1000; - assert defaultConfiguration.getConcurrencyLevel() == 100; - assert defaultConfiguration.getIsolationLevel() == IsolationLevel.READ_COMMITTED; - - Map<String, Configuration> namedCaches = parser.parseNamedConfigurations(); - - Configuration c = namedCaches.get("transactional"); - - assert c.getTransactionManagerLookupClass().equals("org.horizon.transaction.GenericTransactionManagerLookup"); - - c = namedCaches.get("syncRepl"); - - assert c.getCacheMode() == Configuration.CacheMode.REPL_SYNC; - assert c.isFetchInMemoryState(); - assert c.getStateRetrievalTimeout() == 15000; - assert c.getSyncReplTimeout() == 15000; - - c = namedCaches.get("asyncRepl"); - - assert c.getCacheMode() == Configuration.CacheMode.REPL_ASYNC; - assert !c.isUseReplQueue(); - assert !c.isUseAsyncSerialization(); - assert c.isFetchInMemoryState(); - assert c.getStateRetrievalTimeout() == 15000; - - c = namedCaches.get("asyncReplQueue"); - - assert c.getCacheMode() == Configuration.CacheMode.REPL_ASYNC; - assert c.isUseReplQueue(); - assert c.isUseAsyncSerialization(); - assert c.isFetchInMemoryState(); - assert c.getStateRetrievalTimeout() == 15000; - - c = namedCaches.get("txSyncRepl"); - - assert c.getTransactionManagerLookupClass().equals("org.horizon.transaction.GenericTransactionManagerLookup"); - assert c.getCacheMode() == Configuration.CacheMode.REPL_SYNC; - assert c.isFetchInMemoryState(); - assert c.getStateRetrievalTimeout() == 15000; - assert c.getSyncReplTimeout() == 15000; - - c = namedCaches.get("overriding"); - - assert c.getTransactionManagerLookupClass() == null; - assert c.getCacheMode() == Configuration.CacheMode.LOCAL; - assert c.getLockAcquisitionTimeout() == 20000; - assert c.getConcurrencyLevel() == 1000; - assert c.getIsolationLevel() == IsolationLevel.REPEATABLE_READ; - } - - public void testConfigurationMerging() throws IOException { - XmlConfigurationParser parser = new XmlConfigurationParserImpl("configs/named-cache-test.xml"); - Configuration defaultCfg = parser.parseDefaultConfiguration(); - Map<String, Configuration> namedCaches = parser.parseNamedConfigurations(); - - Configuration c = defaultCfg.clone(); - c.applyOverrides(namedCaches.get("transactional")); - - assert c.getCacheMode() == Configuration.CacheMode.LOCAL; - assert c.getTransactionManagerLookupClass().equals("org.horizon.transaction.GenericTransactionManagerLookup"); - assert c.getLockAcquisitionTimeout() == 1000; - assert c.getConcurrencyLevel() == 100; - assert c.getIsolationLevel() == IsolationLevel.READ_COMMITTED; - - c = defaultCfg.clone(); - c.applyOverrides(namedCaches.get("syncRepl")); - - assert c.getTransactionManagerLookupClass() == null; - assert c.getCacheMode() == Configuration.CacheMode.REPL_SYNC; - assert c.isFetchInMemoryState(); - assert c.getStateRetrievalTimeout() == 15000; - assert c.getSyncReplTimeout() == 15000; - assert c.getLockAcquisitionTimeout() == 1000; - assert c.getIsolationLevel() == IsolationLevel.READ_COMMITTED; - assert c.getConcurrencyLevel() == 100; - - c = defaultCfg.clone(); - c.applyOverrides(namedCaches.get("asyncRepl")); - - assert c.getTransactionManagerLookupClass() == null; - assert c.getCacheMode() == Configuration.CacheMode.REPL_ASYNC; - assert !c.isUseReplQueue(); - assert !c.isUseAsyncSerialization(); - assert c.isFetchInMemoryState(); - assert c.getStateRetrievalTimeout() == 15000; - assert c.getLockAcquisitionTimeout() == 1000; - assert c.getIsolationLevel() == IsolationLevel.READ_COMMITTED; - assert c.getConcurrencyLevel() == 100; - - c = defaultCfg.clone(); - c.applyOverrides(namedCaches.get("asyncReplQueue")); - - assert c.getTransactionManagerLookupClass() == null; - assert c.getCacheMode() == Configuration.CacheMode.REPL_ASYNC; - assert c.isUseReplQueue(); - assert c.isUseAsyncSerialization(); - assert c.isFetchInMemoryState(); - assert c.getStateRetrievalTimeout() == 15000; - assert c.getLockAcquisitionTimeout() == 1000; - assert c.getIsolationLevel() == IsolationLevel.READ_COMMITTED; - assert c.getConcurrencyLevel() == 100; - - c = defaultCfg.clone(); - c.applyOverrides(namedCaches.get("txSyncRepl")); - assert c.getTransactionManagerLookupClass().equals("org.horizon.transaction.GenericTransactionManagerLookup"); - assert c.getCacheMode() == Configuration.CacheMode.REPL_SYNC; - assert c.isFetchInMemoryState(); - assert c.getStateRetrievalTimeout() == 15000; - assert c.getSyncReplTimeout() == 15000; - assert c.getLockAcquisitionTimeout() == 1000; - assert c.getIsolationLevel() == IsolationLevel.READ_COMMITTED; - assert c.getConcurrencyLevel() == 100; - - c = defaultCfg.clone(); - c.applyOverrides(namedCaches.get("overriding")); - - assert c.getTransactionManagerLookupClass() == null; - assert c.getCacheMode() == Configuration.CacheMode.LOCAL; - assert c.getLockAcquisitionTimeout() == 20000; - assert c.getConcurrencyLevel() == 1000; - assert c.getIsolationLevel() == IsolationLevel.REPEATABLE_READ; - } -}