Changeset 48 for trunk/src/test/java/omq/test/multiProcess/ClientTest.java

Timestamp:

06/19/13 11:14:58 (11 years ago)

Author:

stoda

Message:

 

File:

• trunk/src/test/java/omq/test/multiProcess/ClientTest.java (modified) (5 diffs)

trunk/src/test/java/omq/test/multiProcess/ClientTest.java

@@ -3 +3 @@
 import static org.junit.Assert.assertEquals;
 
+import java.util.Arrays;
+import java.util.Collection;
 import java.util.Properties;
 
@@ -9 +11 @@
 import omq.common.util.Serializer;
 
-import org.junit.BeforeClass;
+import org.junit.After;
 import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.junit.runners.Parameterized;
+import org.junit.runners.Parameterized.Parameters;
 
+@RunWith(value = Parameterized.class)
 public class ClientTest {
         // Execute ServerTest.java 2 times before start this test
-        public static Number remoteNumber;
+        public Number remoteNumber;
 
-        @BeforeClass
-        public static void startClient() throws Exception {
+        public ClientTest(String type) throws Exception {
                 Properties env = new Properties();
                 env.setProperty(ParameterQueue.USER_NAME, "guest");
@@ -26 +31 @@
                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
-                env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
+                env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
 
@@ -41 +46 @@
         }
 
+        @Parameters
+        public static Collection<Object[]> data() {
+                Object[][] data = new Object[][] { { Serializer.java }, { Serializer.gson }, { Serializer.kryo } };
+                return Arrays.asList(data);
+        }
+
+        @After
+        public void stop() throws Exception {
+                Broker.stopBroker();
+        }
+
         @Test
         public void test() {
@@ -46 +62 @@
                 remoteNumber.setNumber(x);
                 int a = remoteNumber.getNumer();
-                assertEquals(a, 0);
+                assertEquals(0, a);
                 int b = remoteNumber.getNumer();
                 assertEquals(x, b);
+                remoteNumber.setNumber(0);
         }