[infinispan-commits] Infinispan SVN: r1892 - in branches/4.1.x/core/src/test/java/org/infinispan: test and 1 other directory.

[infinispan-commits at lists.jboss.org]

Author: mircea.markus
Date: 2010-06-07 08:15:52 -0400 (Mon, 07 Jun 2010)
New Revision: 1892

Added:
   branches/4.1.x/core/src/test/java/org/infinispan/api/AsyncWithTxTest.java
Modified:
   branches/4.1.x/core/src/test/java/org/infinispan/test/MultipleCacheManagersTest.java
Log:
add UT to check behavior

Added: branches/4.1.x/core/src/test/java/org/infinispan/api/AsyncWithTxTest.java
===================================================================
--- branches/4.1.x/core/src/test/java/org/infinispan/api/AsyncWithTxTest.java	                        (rev 0)
+++ branches/4.1.x/core/src/test/java/org/infinispan/api/AsyncWithTxTest.java	2010-06-07 12:15:52 UTC (rev 1892)
@@ -0,0 +1,33 @@
+package org.infinispan.api;
+
+import org.infinispan.config.Configuration;
+import org.infinispan.test.MultipleCacheManagersTest;
+import org.infinispan.test.TestingUtil;
+import org.infinispan.util.concurrent.NotifyingFuture;
+import org.testng.annotations.Test;
+
+import javax.transaction.TransactionManager;
+import java.util.concurrent.TimeUnit;
+
+/**
+ * @author Mircea.Markus at jboss.com
+ * @since 4.1
+ */
+ at Test(groups = "functional", testName = "api.AsyncWithTxTest")
+public class AsyncWithTxTest extends MultipleCacheManagersTest {
+   @Override
+   protected void createCacheManagers() throws Throwable {
+      Configuration defaultConfig = getDefaultClusteredConfig(Configuration.CacheMode.DIST_SYNC, true);
+      addClusterEnabledCacheManager(defaultConfig);
+      addClusterEnabledCacheManager(defaultConfig);
+   }
+
+   public void testWithTx() throws Exception {
+      TransactionManager transactionManager = TestingUtil.getTransactionManager(cache(0));
+      cache(0).put("k","v1");
+      transactionManager.begin();
+      NotifyingFuture future = cache(0).putAsync("k", "v2");
+      "v1".equals(future.get(2000, TimeUnit.MILLISECONDS));
+      transactionManager.commit();
+   }
+}

Modified: branches/4.1.x/core/src/test/java/org/infinispan/test/MultipleCacheManagersTest.java
===================================================================
--- branches/4.1.x/core/src/test/java/org/infinispan/test/MultipleCacheManagersTest.java	2010-06-03 15:04:33 UTC (rev 1891)
+++ branches/4.1.x/core/src/test/java/org/infinispan/test/MultipleCacheManagersTest.java	2010-06-07 12:15:52 UTC (rev 1892)
@@ -202,6 +202,13 @@
    }
 
    /**
+    * Returns the default cache from that manager.
+    */
+   protected Cache cache(int index) {
+      return manager(index).getCache();
+   }
+
+   /**
     * Create the cache managers you need for your test.  Note that the cache managers you create *must* be created using
     * {@link #addClusterEnabledCacheManager()}
     */