[infinispan-commits] Infinispan SVN: r1596 - trunk/server/hotrod/src/test/scala/org/infinispan/server/hotrod.
infinispan-commits at lists.jboss.org
infinispan-commits at lists.jboss.org
Thu Mar 11 03:56:33 EST 2010
Author: galder.zamarreno at jboss.com
Date: 2010-03-11 03:56:33 -0500 (Thu, 11 Mar 2010)
New Revision: 1596
Added:
trunk/server/hotrod/src/test/scala/org/infinispan/server/hotrod/ClusterTest.scala
Log:
[ISPN-171] (Build a server module based on the HotRod protocol) Forgot to add ClusterTest.
Added: trunk/server/hotrod/src/test/scala/org/infinispan/server/hotrod/ClusterTest.scala
===================================================================
--- trunk/server/hotrod/src/test/scala/org/infinispan/server/hotrod/ClusterTest.scala (rev 0)
+++ trunk/server/hotrod/src/test/scala/org/infinispan/server/hotrod/ClusterTest.scala 2010-03-11 08:56:33 UTC (rev 1596)
@@ -0,0 +1,51 @@
+package org.infinispan.server.hotrod
+
+import org.infinispan.test.MultipleCacheManagersTest
+import org.infinispan.config.Configuration
+import org.jboss.netty.channel.Channel
+import test.{Utils, Client}
+import java.lang.reflect.Method
+import org.infinispan.manager.CacheManager
+import org.testng.annotations.{BeforeClass, AfterClass, Test}
+import org.infinispan.config.Configuration.CacheMode
+
+/**
+ * // TODO: Document this
+ * @author Galder Zamarreño
+ * @since
+ */
+
+ at Test(groups = Array("functional"), testName = "server.hotrod.ClusterTest")
+class ClusterTest extends MultipleCacheManagersTest with Utils with Client {
+ private val cacheName = "hotRodReplSync"
+ private var servers: List[HotRodServer] = List()
+ private var channels: List[Channel] = List()
+
+ @Test(enabled=false) // Disable explicitly to avoid TestNG thinking this is a test!!
+ override def createCacheManagers {
+ var replSync = getDefaultClusteredConfig(Configuration.CacheMode.REPL_SYNC)
+ createClusteredCaches(2, cacheName, replSync)
+ servers = createHotRodServer(cacheManagers.get(0)) :: servers
+ servers = createHotRodServer(cacheManagers.get(1), servers.head.port + 50) :: servers
+ servers.foreach {
+ s => s.start
+ channels = connect("127.0.0.1", s.port) :: channels
+ }
+ }
+
+ @AfterClass(alwaysRun = true)
+ override def destroy {
+ super.destroy
+ log.debug("Test finished, close Hot Rod server", null)
+ servers.foreach(_.stop)
+ }
+
+ @Test
+ def tesReplicatedPut(m: Method) {
+ val putSt = put(channels.head, cacheName, k(m) , 0, 0, v(m))
+ assertSuccess(putSt)
+ val (getSt, actual) = get(channels.tail.head, cacheName, k(m), null)
+ assertSuccess(getSt, v(m), actual)
+ }
+
+}
\ No newline at end of file
More information about the infinispan-commits
mailing list