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


Ignore:
Timestamp:
06/21/13 12:42:25 (11 years ago)
Author:
stoda
Message:

Adding @MultiMethod?
Broker is not a singleton.

Location:
trunk/src/test/java/omq/test
Files:
1 added
8 deleted
6 edited
5 moved

Legend:

Unmodified
Added
Removed

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

    r46 r54  
    33import java.io.IOException;
    44
    5 import omq.common.broker.Broker;
    65import omq.exception.SerializerException;
    76import omq.server.RemoteObject;
    … …  
    3635        @Override
    3736        public void asyncDivideByZero() throws IOException, SerializerException {
    38                 ZeroEvent ze = new ZeroEvent("my zero event", "zero-event");
    39                 Broker.trigger(ze);
    40                 //notifyEvent(ze);
     37                // ZeroEvent ze = new ZeroEvent("my zero event", "zero-event");
     38                // Broker.trigger(ze);
     39                // notifyEvent(ze);
    4140        }
    4241
    4342        @Override
    4443        public void sendMessage(Message m) {
    45                 System.out.println("Code = "+m.getCode());
    46                 System.out.println("Message = "+m.getMessage());
     44                System.out.println("Code = " + m.getCode());
     45                System.out.println("Message = " + m.getMessage());
    4746        }
    4847

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

    r51 r54  
    1212
    1313import org.junit.After;
     14import org.junit.BeforeClass;
    1415import org.junit.Test;
    1516import org.junit.runner.RunWith;
    … …  
    1819
    1920@RunWith(value = Parameterized.class)
    20 public class ClientTest {
     21public class CalculatorTest {
    2122
     23        private static Broker broker;
    2224        private static Calculator remoteCalc;
    2325        private static Calculator remoteCalc2;
    2426
    25         public ClientTest(String type) throws Exception {
     27        public CalculatorTest(String type) throws Exception {
    2628                Properties env = new Properties();
    2729                env.setProperty(ParameterQueue.USER_NAME, "guest");
    … …  
    4446                env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");
    4547
    46                 Broker.initBroker(env);
    47                 remoteCalc = (Calculator) Broker.lookup("calculator1", Calculator.class);
    48                 remoteCalc2 = (Calculator) Broker.lookup("calculator2", Calculator.class);
     48                broker = new Broker(env);
     49                remoteCalc = broker.lookup("calculator1", Calculator.class);
     50                remoteCalc2 = broker.lookup("calculator2", Calculator.class);
    4951        }
    5052
    … …  
    5557        }
    5658
     59        @BeforeClass
     60        public static void server() throws Exception {
     61                Properties env = new Properties();
     62                env.setProperty(ParameterQueue.USER_NAME, "guest");
     63                env.setProperty(ParameterQueue.USER_PASS, "guest");
     64
     65                // Get host info of rabbimq (where it is)
     66                env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
     67                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     68                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     69                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     70
     71                // Set info about where the message will be sent
     72                env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
     73                env.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000");
     74
     75                CalculatorImpl calc = new CalculatorImpl();
     76                CalculatorImpl calc2 = new CalculatorImpl();
     77
     78                Broker broker = new Broker(env);
     79                broker.bind("calculator1", calc);
     80                broker.bind("calculator2", calc2);
     81
     82                System.out.println("Server started");
     83        }
     84
    5785        @After
    5886        public void stop() throws Exception {
    59                 Broker.stopBroker();
     87                broker.stopBroker();
    6088        }
    6189

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

    r47 r54  
    1313
    1414import org.junit.After;
     15import org.junit.BeforeClass;
    1516import org.junit.Test;
    1617import org.junit.runner.RunWith;
    … …  
    1920
    2021@RunWith(value = Parameterized.class)
    21 public class ClientTest {
    22         private ClientInterface client;
     22public class ExceptionTest {
     23        private static Broker broker;
     24        private static ClientInterface client;
    2325
    24         public ClientTest(String type) throws Exception {
     26        public ExceptionTest(String type) throws Exception {
    2527                Properties env = new Properties();
    2628                env.setProperty(ParameterQueue.USER_NAME, "guest");
    … …  
    4244                env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");
    4345
    44                 Broker.initBroker(env);
    45                 client = (ClientInterface) Broker.lookup("server", ClientInterface.class);
     46                broker = new Broker(env);
     47                client = broker.lookup("server", ClientInterface.class);
    4648        }
    4749
    … …  
    5254        }
    5355
     56        @BeforeClass
     57        public static void serverTest() throws Exception {
     58                Properties env = new Properties();
     59                env.setProperty(ParameterQueue.USER_NAME, "guest");
     60                env.setProperty(ParameterQueue.USER_PASS, "guest");
     61
     62                // Get host info of rabbimq (where it is)
     63                env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
     64                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     65                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     66                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     67
     68                // Set info about where the message will be sent
     69                env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
     70                env.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000");
     71
     72                OmqServerImpl server = new OmqServerImpl();
     73
     74                Broker broker = new Broker(env);
     75                broker.bind("server", server);
     76        }
     77
    5478        @After
    5579        public void stop() throws Exception {
    56                 Broker.stopBroker();
     80                broker.stopBroker();
    5781        }
    5882

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

    r47 r54  
    2828                OmqServerImpl server = new OmqServerImpl();
    2929
    30                 Broker.initBroker(env);
    31                 Broker.bind("server", server);
     30                Broker broker = new Broker(env);
     31                broker.bind("server", server);
    3232
    3333                Thread.sleep(60 * 60 * 1000);
    3434        }
    3535}
     36;

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

    r46 r54  
    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;
    1012import omq.test.calculator.Calculator;
     13import omq.test.calculator.CalculatorImpl;
    1114
     15import org.junit.After;
    1216import org.junit.BeforeClass;
    1317import org.junit.Test;
     18import org.junit.runner.RunWith;
     19import org.junit.runners.Parameterized;
     20import org.junit.runners.Parameterized.Parameters;
    1421
    15 
    16 public class ClientTest {
     22@RunWith(value = Parameterized.class)
     23public class FaultToleranceTest {
     24        private static Broker broker;
    1725        private static Calculator remoteCalc;
    1826
    19         @BeforeClass
    20         public static void startClient() throws Exception {
     27        public FaultToleranceTest(String type) throws Exception {
    2128                Properties env = new Properties();
    2229                env.setProperty(ParameterQueue.USER_NAME, "guest");
    … …  
    2734                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
    2835                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    29                 env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
     36                env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    3037                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
    3138
    … …  
    4047                env.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "5000");
    4148
    42                 Broker.initBroker(env);
    43                 remoteCalc = (Calculator) Broker.lookup("calculator1", Calculator.class);
     49                broker = new Broker(env);
     50                remoteCalc = broker.lookup("calculator1", Calculator.class);
     51        }
     52
     53        @Parameters
     54        public static Collection<Object[]> data() {
     55                Object[][] data = new Object[][] { { Serializer.java }, { Serializer.gson }, { Serializer.kryo } };
     56                return Arrays.asList(data);
     57        }
     58
     59        @After
     60        public void stop() throws Exception {
     61                broker.stopBroker();
     62        }
     63
     64        @BeforeClass
     65        public static void serverTest() throws Exception {
     66                Properties env = new Properties();
     67                env.setProperty(ParameterQueue.USER_NAME, "guest");
     68                env.setProperty(ParameterQueue.USER_PASS, "guest");
     69
     70                // Get host info of rabbimq (where it is)
     71                env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
     72                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     73                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     74                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     75
     76                // Set info about where the message will be sent
     77                env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
     78                env.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000");
     79
     80                CalculatorImpl calc = new CalculatorImpl();
     81
     82                broker = new Broker(env);
     83                broker.bind("calculator1", calc);
     84
     85                System.out.println("Server started");
    4486        }
    4587

  • trunk/src/test/java/omq/test/multiProcess/MultiProcessTest.java

    r48 r54  
    1212
    1313import org.junit.After;
     14import org.junit.BeforeClass;
    1415import org.junit.Test;
    1516import org.junit.runner.RunWith;
    … …  
    1819
    1920@RunWith(value = Parameterized.class)
    20 public class ClientTest {
    21         // Execute ServerTest.java 2 times before start this test
    22         public Number remoteNumber;
     21public class MultiProcessTest {
     22        public static Broker broker;
     23        public static Number remoteNumber;
    2324
    24         public ClientTest(String type) throws Exception {
     25        public MultiProcessTest(String type) throws Exception {
    2526                Properties env = new Properties();
    2627                env.setProperty(ParameterQueue.USER_NAME, "guest");
    … …  
    4243                env.setProperty(ParameterQueue.EVENT_REPLY_QUEUE, "event_queue");
    4344
    44                 Broker.initBroker(env);
    45                 remoteNumber = Broker.lookup("number", Number.class);
     45                broker = new Broker(env);
     46                remoteNumber = broker.lookup("number", Number.class);
    4647        }
    4748
    … …  
    5253        }
    5354
     55        @BeforeClass
     56        public static void serverTest() throws Exception {
     57                Properties env = new Properties();
     58                env.setProperty(ParameterQueue.USER_NAME, "guest");
     59                env.setProperty(ParameterQueue.USER_PASS, "guest");
     60
     61                // Get host info of rabbimq (where it is)
     62                env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
     63                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     64                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     65                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     66
     67                // Set info about where the message will be sent
     68                env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
     69                env.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000");
     70
     71                Broker broker = new Broker(env);
     72                broker.bind("number", new NumberImpl());
     73
     74                Broker broker2 = new Broker(env);
     75                broker2.bind("number", new NumberImpl());
     76        }
     77
    5478        @After
    5579        public void stop() throws Exception {
    56                 Broker.stopBroker();
     80                broker.stopBroker();
    5781        }
    5882
    5983        @Test
    60         public void test() {
     84        public void fifoTest() {
    6185                int x = 10;
    6286                remoteNumber.setNumber(x);
    … …  
    6892        }
    6993
     94        @Test
     95        public void multiTest() throws Exception {
     96                int x = 10;
     97                remoteNumber.setMultiNumber(x);
     98                Thread.sleep(200);
     99                int a = remoteNumber.getNumer();
     100                assertEquals(x, a);
     101                remoteNumber.setMultiNumber(0);
     102                Thread.sleep(200);
     103        }
     104
    70105}

  • trunk/src/test/java/omq/test/multiProcess/Number.java

    r46 r54  
    22
    33import omq.Remote;
     4import omq.client.annotation.AsyncMethod;
     5import omq.client.annotation.MultiMethod;
    46import omq.client.annotation.RemoteInterface;
    57import omq.client.annotation.SyncMethod;
    … …  
    1214        @SyncMethod(timeout = 1000)
    1315        public int getNumer();
     16
     17        @MultiMethod
     18        @AsyncMethod
     19        public void setMultiNumber(int x);
    1420}

  • trunk/src/test/java/omq/test/multiProcess/NumberImpl.java

    r46 r54  
    11package omq.test.multiProcess;
    22
     3import omq.client.annotation.AsyncMethod;
     4import omq.client.annotation.MultiMethod;
    35import omq.client.annotation.SyncMethod;
    46import omq.server.RemoteObject;
    … …  
    3032        }
    3133
     34        @Override
     35        @MultiMethod
     36        @AsyncMethod
     37        public void setMultiNumber(int x) {
     38                this.x = x;
     39        }
     40
    3241}

  • trunk/src/test/java/omq/test/stopBroker/BrokerKillerImpl.java

    r46 r54  
    1212        private static final long serialVersionUID = 1L;
    1313
     14        private Broker broker;
     15
     16        public BrokerKillerImpl(Broker broker) {
     17                this.broker = broker;
     18        }
     19
    1420        @Override
    1521        @AsyncMethod
    … …  
    2430                                try {
    2531                                        Thread.sleep(1000);
    26                                         Broker.stopBroker();
     32                                        broker.stopBroker();
    2733                                } catch (Exception e) {
    2834                                        e.printStackTrace();

  • trunk/src/test/java/omq/test/stopBroker/StopBrokerTest.java

    r46 r54  
    11package omq.test.stopBroker;
    22
     3import java.util.Arrays;
     4import java.util.Collection;
    35import java.util.Properties;
    46
    … …  
    79import omq.common.util.Serializer;
    810
    9 public class ClientTest {
     11import org.junit.After;
     12import org.junit.BeforeClass;
     13import org.junit.Test;
     14import org.junit.runner.RunWith;
     15import org.junit.runners.Parameterized;
     16import org.junit.runners.Parameterized.Parameters;
    1017
    11         /**
    12          * @param args
    13          * @throws Exception
    14          */
    15         public static void main(String[] args) throws Exception {
     18@RunWith(value = Parameterized.class)
     19public class StopBrokerTest {
     20
     21        private static Broker broker;
     22        private static BrokerKiller bk;
     23
     24        public StopBrokerTest(String type) throws Exception {
    1625                Properties env = new Properties();
    1726                env.setProperty(ParameterQueue.USER_NAME, "guest");
    … …  
    2231                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
    2332                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    24                 env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
     33                env.setProperty(ParameterQueue.SERIALIZER_NAME, type);
    2534                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
    2635
    … …  
    3544                env.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "5000");
    3645
    37                 Broker.initBroker(env);
    38                 BrokerKiller bk = (BrokerKiller) Broker.lookup("bk", BrokerKiller.class);
     46                broker = new Broker(env);
     47                bk = broker.lookup("bk", BrokerKiller.class);
     48        }
    3949
     50        @Parameters
     51        public static Collection<Object[]> data() {
     52                Object[][] data = new Object[][] { { Serializer.java }, { Serializer.gson }, { Serializer.kryo } };
     53                return Arrays.asList(data);
     54        }
     55
     56        @BeforeClass
     57        public static void server() throws Exception {
     58                Properties env = new Properties();
     59                env.setProperty(ParameterQueue.USER_NAME, "guest");
     60                env.setProperty(ParameterQueue.USER_PASS, "guest");
     61
     62                // Get host info of rabbimq (where it is)
     63                env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
     64                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
     65                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
     66                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
     67
     68                // Set info about where the message will be sent
     69                env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
     70                env.setProperty(ParameterQueue.RETRY_TIME_CONNECTION, "2000");
     71
     72                Broker broker = new Broker(env);
     73                BrokerKillerImpl bki = new BrokerKillerImpl(broker);
     74                broker.bind("bk", bki);
     75        }
     76
     77        @After
     78        public void stop() throws Exception {
     79                broker.stopBroker();
     80        }
     81
     82        @Test
     83        public void stopBroker() throws Exception {
    4084                bk.killServerBroker();
    41                 Broker.stopBroker();
    4285        }
    4386

  • trunk/src/test/java/omq/test/stopBroker/UnbindTest.java

    r46 r54  
    55import omq.common.broker.Broker;
    66import omq.common.util.ParameterQueue;
    7 import omq.common.util.Serializer;
    87import omq.test.calculator.CalculatorImpl;
    98
     9import org.junit.Test;
     10
    1011public class UnbindTest {
    11         private static CalculatorImpl calc;
    1212
    13         /**
    14          * @param args
    15          */
    16         public static void main(String[] args) throws Exception {
     13        @Test
     14        public void serverTest() throws Exception {
    1715                Properties env = new Properties();
    1816                env.setProperty(ParameterQueue.USER_NAME, "guest");
    … …  
    2321                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
    2422                env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
    25                 env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
    2623                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
    2724
    … …  
    3128
    3229                String reference = "calculator1";
    33                 calc = new CalculatorImpl();
     30                CalculatorImpl calc = new CalculatorImpl();
    3431
    35                 Broker.initBroker(env);
    36                 Broker.bind(reference, calc);
     32                Broker broker = new Broker(env);
     33                broker.bind(reference, calc);
    3734
    38                 Broker.unbind(reference);
     35                broker.unbind(reference);
    3936
    40                 Broker.closeConnection();
     37                broker.closeConnection();
    4138        }
    4239
Note: See TracChangeset for help on using the changeset viewer.