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


Ignore:
Timestamp:
06/18/13 16:51:22 (11 years ago)
Author:
stoda
Message:

Refactoring Environment class - deleted.
StopBroker? problems solved (?)
Server can receive send and receive messages in different formats.
Some tests modified

TODO: finish all the tests, add log4j

Location:
trunk/src/test/java/omq/test
Files:
3 added
6 edited
1 copied

Legend:

Unmodified
Added
Removed

  • trunk/src/test/java/omq/test/calculator/Calculator.java

    r46 r47  
    2323        public void asyncDivideByZero() throws IOException, SerializerException;
    2424
    25         @SyncMethod
     25        @SyncMethod(timeout = 1500)
    2626        public int divideByZero();
    2727

  • trunk/src/test/java/omq/test/calculator/ClientJava.java

    r46 r47  
    99import omq.common.util.Serializer;
    1010
     11import org.junit.AfterClass;
    1112import org.junit.BeforeClass;
    1213import org.junit.Test;
    1314
    14 public class ClientTest {
     15public class ClientJava {
    1516        private static Calculator remoteCalc;
    1617        private static Calculator remoteCalc2;
    … …  
    4142                remoteCalc = (Calculator) Broker.lookup("calculator1", Calculator.class);
    4243                remoteCalc2 = (Calculator) Broker.lookup("calculator2", Calculator.class);
     44        }
     45
     46        @AfterClass
     47        public static void stop() throws Exception {
     48                Broker.stopBroker();
     49                Thread.sleep(1000);
    4350        }
    4451

  • trunk/src/test/java/omq/test/calculator/ClientTest.java

    r46 r47  
    11package omq.test.calculator;
    22
    3 import static org.junit.Assert.assertEquals;
     3import org.junit.runner.RunWith;
     4import org.junit.runners.Suite;
    45
    5 import java.util.Properties;
    6 
    7 import omq.common.broker.Broker;
    8 import omq.common.util.ParameterQueue;
    9 import omq.common.util.Serializer;
    10 
    11 import org.junit.BeforeClass;
    12 import org.junit.Test;
    13 
     6@RunWith(Suite.class)
     7@Suite.SuiteClasses({ ClientJava.class, ClientGson.class, ClientKryo.class })
    148public class ClientTest {
    15         private static Calculator remoteCalc;
    16         private static Calculator remoteCalc2;
    17 
    18         @BeforeClass
    19         public static void startClient() throws Exception {
    20                 Properties env = new Properties();
    21                 env.setProperty(ParameterQueue.USER_NAME, "guest");
    22                 env.setProperty(ParameterQueue.USER_PASS, "guest");
    23 
    24                 // Set host info of rabbimq (where it is)
    25                 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
    26                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
    27                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    28                 env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
    29                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
    30 
    31                 // Set info about where the message will be sent
    32                 env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
    33                 // env.setProperty(ParameterQueue.DEBUGFILE, "c:\\middlewareDebug");
    34 
    35                 // Set info about the queue & the exchange where the ResponseListener
    36                 // will listen to.
    37                 env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, "reply_queue");
    38                 env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");
    39 
    40                 Broker.initBroker(env);
    41                 remoteCalc = (Calculator) Broker.lookup("calculator1", Calculator.class);
    42                 remoteCalc2 = (Calculator) Broker.lookup("calculator2", Calculator.class);
    43         }
    44 
    45         @Test
    46         public void add() throws Exception {
    47                 int x = 10;
    48                 int y = 20;
    49 
    50                 int sync = remoteCalc.add(x, y);
    51                 int sum = x + y;
    52 
    53                 assertEquals(sum, sync);
    54         }
    55 
    56         @Test
    57         public void add2() throws Exception {
    58                 int x = 10;
    59                 int y = 20;
    60 
    61                 int sync = remoteCalc2.add(x, y);
    62                 int sum = x + y;
    63 
    64                 assertEquals(sum, sync);
    65         }
    66 
    67         @Test
    68         public void mult() throws Exception {
    69                 int x = 5;
    70                 int y = 15;
    71 
    72                 remoteCalc.mult(x, y);
    73                 Thread.sleep(200);
    74         }
    75 
    76         @Test
    77         public void notifyEvent() throws Exception {
    78                 ZeroListener zL = new ZeroListener("zero-event");
    79 
    80                 remoteCalc.addListener(zL);
    81 
    82                 remoteCalc.asyncDivideByZero();
    83 
    84                 Thread.sleep(200);
    85         }
    86 
    87         @Test
    88         public void sendMessage() throws Exception {
    89                 Message m = new Message(2334, "Hello objectmq");
    90                 remoteCalc.sendMessage(m);
    91         }
    92 
    93         @Test(expected = ArithmeticException.class)
    94         public void divideByZero() {
    95                 remoteCalc.divideByZero();
    96         }
    979}

  • trunk/src/test/java/omq/test/calculator/ServerTest.java

    r46 r47  
    22
    33import java.util.Properties;
     4
     5import org.junit.Test;
    46
    57import omq.common.broker.Broker;
    … …  
    810
    911public class ServerTest {
    10         private static CalculatorImpl calc;
    11         private static CalculatorImpl calc2;
    1212
    13         public static void main(String[] args) throws Exception {
     13        private CalculatorImpl calc;
     14        private CalculatorImpl calc2;
     15
     16        @Test
     17        public void serverTest() throws Exception {
    1418                Properties env = new Properties();
    1519                env.setProperty(ParameterQueue.USER_NAME, "guest");
    … …  
    3539
    3640                System.out.println("Server started");
     41
     42                Thread.sleep(60 * 60 * 1000);
    3743        }
    3844}

  • trunk/src/test/java/omq/test/exception/ClientTest.java

    r46 r47  
    44
    55import java.lang.reflect.UndeclaredThrowableException;
     6import java.util.Arrays;
     7import java.util.Collection;
    68import java.util.Properties;
    79
    … …  
    1012import omq.common.util.Serializer;
    1113
    12 import org.junit.BeforeClass;
     14import org.junit.After;
    1315import org.junit.Test;
     16import org.junit.runner.RunWith;
     17import org.junit.runners.Parameterized;
     18import org.junit.runners.Parameterized.Parameters;
    1419
     20@RunWith(value = Parameterized.class)
    1521public class ClientTest {
    16         private static ClientInterface client;
     22        private ClientInterface client;
    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.kryo);
     33                env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    2934                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
    3035
    … …  
    3944                Broker.initBroker(env);
    4045                client = (ClientInterface) Broker.lookup("server", ClientInterface.class);
     46        }
     47
     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();
    4157        }
    4258

  • trunk/src/test/java/omq/test/exception/ServerTest.java

    r46 r47  
    55import omq.common.broker.Broker;
    66import omq.common.util.ParameterQueue;
    7 import omq.common.util.Serializer;
     7
     8import org.junit.Test;
    89
    910public class ServerTest {
    1011
    11         public static void main(String[] args) throws Exception {
     12        @Test
     13        public void test() throws Exception {
    1214                Properties env = new Properties();
    1315                env.setProperty(ParameterQueue.USER_NAME, "guest");
    … …  
    1820                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
    1921                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    20                 env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.kryo);
    2122                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
    2223
    … …  
    2930                Broker.initBroker(env);
    3031                Broker.bind("server", server);
     32
     33                Thread.sleep(60 * 60 * 1000);
    3134        }
    3235}

  • trunk/src/test/java/omq/test/faultTolerance/ServerTest.java

    r46 r47  
    22
    33import java.util.Properties;
     4
     5import org.junit.Test;
    46
    57import omq.common.broker.Broker;
    … …  
    1113        private static CalculatorImpl calc;
    1214
    13         public static void main(String[] args) throws Exception {
     15        @Test
     16        public void test() throws Exception {
    1417                Properties env = new Properties();
    1518                env.setProperty(ParameterQueue.USER_NAME, "guest");
    … …  
    3336
    3437                System.out.println("Server started");
     38               
     39                Thread.sleep(60 * 1000);
    3540        }
    3641}
Note: See TracChangeset for help on using the changeset viewer.