[infinispan-commits] Infinispan SVN: r2213 - in branches/4.1.x: tree/src/test/java/org/infinispan and 1 other directories.

[infinispan-commits at lists.jboss.org]

Author: manik.surtani at jboss.com
Date: 2010-08-13 10:12:53 -0400 (Fri, 13 Aug 2010)
New Revision: 2213

Added:
   branches/4.1.x/core/src/test/java/org/infinispan/tx/TransactionManagerLookupTest.java
   branches/4.1.x/tree/src/test/java/org/infinispan/tx/
   branches/4.1.x/tree/src/test/java/org/infinispan/tx/TransactionManagerLookupTreeTest.java
Log:
[ISPN-600] (Embedded JBossTS and TreeCache don't work together)

Added: branches/4.1.x/core/src/test/java/org/infinispan/tx/TransactionManagerLookupTest.java
===================================================================
--- branches/4.1.x/core/src/test/java/org/infinispan/tx/TransactionManagerLookupTest.java	                        (rev 0)
+++ branches/4.1.x/core/src/test/java/org/infinispan/tx/TransactionManagerLookupTest.java	2010-08-13 14:12:53 UTC (rev 2213)
@@ -0,0 +1,43 @@
+package org.infinispan.tx;
+
+import org.infinispan.test.AbstractInfinispanTest;
+import org.infinispan.transaction.lookup.DummyTransactionManagerLookup;
+import org.infinispan.transaction.lookup.GenericTransactionManagerLookup;
+import org.infinispan.transaction.lookup.JBossStandaloneJTAManagerLookup;
+import org.infinispan.transaction.lookup.JBossTransactionManagerLookup;
+import org.infinispan.transaction.lookup.TransactionManagerLookup;
+import org.testng.annotations.Test;
+
+import javax.transaction.TransactionManager;
+
+/**
+ * Tests all TransactionManagerLookup impls shipped with Infinispan for correctness
+ *
+ * @author Manik Surtani
+ * @version 4.1
+ */
+ at Test(testName = "tx.TransactionManagerLookupTest", groups = "unit")
+public class TransactionManagerLookupTest extends AbstractInfinispanTest {
+
+   public void testGenericTransactionManagerLookup() throws Exception {
+      doTest(new GenericTransactionManagerLookup());
+   }
+
+   public void testDummyTransactionManagerLookup() throws Exception {
+      doTest(new DummyTransactionManagerLookup());
+   }
+
+   public void testJBossStandaloneJTAManagerLookup() throws Exception {
+      doTest(new JBossStandaloneJTAManagerLookup());
+   }
+   
+   protected void doTest(TransactionManagerLookup lookup) throws Exception {
+      TransactionManager tm = lookup.getTransactionManager();
+      tm.begin();
+      tm.commit();
+
+      tm.begin();
+      tm.rollback();
+   }
+
+}

Added: branches/4.1.x/tree/src/test/java/org/infinispan/tx/TransactionManagerLookupTreeTest.java
===================================================================
--- branches/4.1.x/tree/src/test/java/org/infinispan/tx/TransactionManagerLookupTreeTest.java	                        (rev 0)
+++ branches/4.1.x/tree/src/test/java/org/infinispan/tx/TransactionManagerLookupTreeTest.java	2010-08-13 14:12:53 UTC (rev 2213)
@@ -0,0 +1,33 @@
+package org.infinispan.tx;
+
+import org.infinispan.config.Configuration;
+import org.infinispan.manager.DefaultCacheManager;
+import org.infinispan.manager.EmbeddedCacheManager;
+import org.infinispan.test.AbstractInfinispanTest;
+import org.infinispan.test.SingleCacheManagerTest;
+import org.infinispan.test.TestingUtil;
+import org.infinispan.transaction.lookup.TransactionManagerLookup;
+import org.infinispan.tree.Fqn;
+import org.infinispan.tree.TreeCache;
+import org.infinispan.tree.TreeCacheFactory;
+import org.testng.annotations.Test;
+
+ at Test(testName = "tx.TransactionManagerLookupTreeTest", groups = "unit")
+public class TransactionManagerLookupTreeTest extends TransactionManagerLookupTest {
+
+   @Override
+   protected void doTest(TransactionManagerLookup tml) {
+      EmbeddedCacheManager ecm = null;
+      try {
+         Configuration c = new Configuration();
+         c.setTransactionManagerLookup(tml);
+         c.setInvocationBatchingEnabled(true);
+         ecm = new DefaultCacheManager(c);
+         TreeCache<Object, Object> tc = new TreeCacheFactory().createTreeCache(ecm.<Object, Object>getCache());
+         tc.put("/a/b/c", "k", "v");
+         assert "v".equals(tc.get("/a/b/c", "k"));
+      } finally {
+         TestingUtil.killCacheManagers(ecm);
+      }
+   }
+}