Changeset 48 for trunk/src/test/java/omq


Ignore:
Timestamp:
06/19/13 11:14:58 (11 years ago)
Author:
stoda
Message:
 
Location:
trunk/src/test/java/omq/test
Files:
5 edited

Legend:

Unmodified
Added
Removed
  • trunk/src/test/java/omq/test/calculator/ServerTest.java

    r47 r48  
    33import java.util.Properties;
    44
    5 import org.junit.Test;
    6 
    75import omq.common.broker.Broker;
    86import omq.common.util.ParameterQueue;
    9 import omq.common.util.Serializer;
     7
     8import org.junit.Test;
    109
    1110public class ServerTest {
     
    2322                env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    2423                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
    25                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "true");
    26                 env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
     24                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    2725                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
    2826
  • trunk/src/test/java/omq/test/faultTolerance/ServerTest.java

    r47 r48  
    33import java.util.Properties;
    44
    5 import org.junit.Test;
    6 
    75import omq.common.broker.Broker;
    86import omq.common.util.ParameterQueue;
    9 import omq.common.util.Serializer;
    107import omq.test.calculator.CalculatorImpl;
     8
     9import org.junit.Test;
    1110
    1211public class ServerTest {
     
    2322                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
    2423                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    25                 env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
    2624                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
    2725
  • trunk/src/test/java/omq/test/multiProcess/ClientTest.java

    r46 r48  
    33import static org.junit.Assert.assertEquals;
    44
     5import java.util.Arrays;
     6import java.util.Collection;
    57import java.util.Properties;
    68
     
    911import omq.common.util.Serializer;
    1012
    11 import org.junit.BeforeClass;
     13import org.junit.After;
    1214import org.junit.Test;
     15import org.junit.runner.RunWith;
     16import org.junit.runners.Parameterized;
     17import org.junit.runners.Parameterized.Parameters;
    1318
     19@RunWith(value = Parameterized.class)
    1420public class ClientTest {
    1521        // Execute ServerTest.java 2 times before start this test
    16         public static Number remoteNumber;
     22        public Number remoteNumber;
    1723
    18         @BeforeClass
    19         public static void startClient() throws Exception {
     24        public ClientTest(String type) throws Exception {
    2025                Properties env = new Properties();
    2126                env.setProperty(ParameterQueue.USER_NAME, "guest");
     
    2631                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
    2732                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    28                 env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
     33                env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    2934                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
    3035
     
    4146        }
    4247
     48        @Parameters
     49        public static Collection<Object[]> data() {
     50                Object[][] data = new Object[][] { { Serializer.java }, { Serializer.gson }, { Serializer.kryo } };
     51                return Arrays.asList(data);
     52        }
     53
     54        @After
     55        public void stop() throws Exception {
     56                Broker.stopBroker();
     57        }
     58
    4359        @Test
    4460        public void test() {
     
    4662                remoteNumber.setNumber(x);
    4763                int a = remoteNumber.getNumer();
    48                 assertEquals(a, 0);
     64                assertEquals(0, a);
    4965                int b = remoteNumber.getNumer();
    5066                assertEquals(x, b);
     67                remoteNumber.setNumber(0);
    5168        }
    5269
  • trunk/src/test/java/omq/test/multiProcess/ServerTest.java

    r46 r48  
    33import java.util.Properties;
    44
     5import org.junit.Test;
     6
    57import omq.common.broker.Broker;
    68import omq.common.util.ParameterQueue;
    7 import omq.common.util.Serializer;
    89
    910public class ServerTest {
    10         public static void main(String[] args) throws Exception {
     11        @Test
     12        public void test() throws Exception {
    1113                Properties env = new Properties();
    1214                env.setProperty(ParameterQueue.USER_NAME, "guest");
     
    1719                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
    1820                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    19                 env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
    2021                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
    2122
     
    2627                Broker.initBroker(env);
    2728                Broker.bind("number", new NumberImpl());
     29
     30                Thread.sleep(60 * 1000);
    2831        }
    2932}
  • trunk/src/test/java/omq/test/stopBroker/ServerTest.java

    r46 r48  
    22
    33import java.util.Properties;
     4
     5import org.junit.Test;
    46
    57import omq.common.broker.Broker;
     
    911public class ServerTest {
    1012
    11         /**
    12          * @param args
    13          */
    14         public static void main(String[] args) throws Exception {
     13        @Test
     14        public void test() throws Exception {
    1515                Properties env = new Properties();
    1616                env.setProperty(ParameterQueue.USER_NAME, "guest");
Note: See TracChangeset for help on using the changeset viewer.