[jbosscache-commits] JBoss Cache SVN: r7664 - core/branches/flat/src/test/java/org/horizon/config/parsing.

[jbosscache-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2009-02-08 06:24:01 -0500 (Sun, 08 Feb 2009)
New Revision: 7664

Added:
   core/branches/flat/src/test/java/org/horizon/config/parsing/XmlFileParsingTest.java
Log:
Restored test

Added: core/branches/flat/src/test/java/org/horizon/config/parsing/XmlFileParsingTest.java
===================================================================
--- core/branches/flat/src/test/java/org/horizon/config/parsing/XmlFileParsingTest.java	                        (rev 0)
+++ core/branches/flat/src/test/java/org/horizon/config/parsing/XmlFileParsingTest.java	2009-02-08 11:24:01 UTC (rev 7664)
@@ -0,0 +1,164 @@
+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;
+
+ at 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;
+   }
+}