Changeset 54


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

Adding @MultiMethod?
Broker is not a singleton.

Location:
trunk
Files:
2 added
9 deleted
15 edited
5 moved

Legend:

Unmodified
Added
Removed

  • trunk/pom.xml

    r52 r54  
    7070                <sourceDirectory>src</sourceDirectory>
    7171                <testSourceDirectory>test</testSourceDirectory>
     72                <resources>
     73                        <resource>
     74                                <directory>src/main/resources</directory>
     75                                <filtering>true</filtering>
     76                                <includes>
     77                                        <include>log4j.xml</include>
     78                                        <include>example.properties</include>
     79                                        <include>version.properties</include>
     80                                </includes>
     81                        </resource>
     82                </resources>
    7283                <plugins>
    7384                        <plugin>

  • trunk/src/main/java/omq/client/listener/ResponseListener.java

    r53 r54  
    5555        @Override
    5656        public void run() {
     57                logger.info("ResponseListener started");
    5758                Delivery delivery;
    5859                String uid_request;
    … …  
    122123
    123124                channel.queueDeclare(reply_queue, durable, false, false, args);
     125                logger.info("ResponseListener creating queue: " + reply_queue + ", durable: " + durable);
    124126
    125127                // Declare a new consumer

  • trunk/src/main/java/omq/client/proxy/Proxymq.java

    r53 r54  
    1515import omq.Remote;
    1616import omq.client.annotation.AsyncMethod;
     17import omq.client.annotation.MultiMethod;
    1718import omq.client.annotation.SyncMethod;
    1819import omq.client.listener.ResponseListener;
    … …  
    133134                Request request = createRequest(method, arguments);
    134135
    135                 // Log.saveTimeSendRequestLog("Client-time-request", request.getId(),
    136                 // method.getName(), timeStart);
    137 
    138136                Object response = null;
    139137                // Publish the request
    … …  
    144142                        logger.debug("Publish sync request -> " + request.getId());
    145143                        response = publishSyncRequest(request, method.getReturnType());
    146 
    147                         // long timeEnd = (new Date()).getTime();
    148                         // Log.saveTimeSendRequestLog("Client-time-response",
    149                         // request.getId(), method.getName(), timeEnd);
    150144                }
    151145
    … …  
    168162                // channel.basicPublish(exchange, routingkey, props, bytesRequest);
    169163                broker.getChannel().basicPublish(exchange, routingkey, props, bytesRequest);
    170                 // Log.saveLog("Client-Serialize", bytesRequest);
    171164        }
    172165
    … …  
    203196                String corrId = java.util.UUID.randomUUID().toString();
    204197                String methodName = method.getName();
     198                boolean multi = false;
     199
     200                if (method.getAnnotation(MultiMethod.class) != null) {
     201                        multi = true;
     202                }
    205203
    206204                // Since we need to know whether the method is async and if it has to
    … …  
    217215                        return Request.newSyncRequest(corrId, methodName, arguments, retries, timeout);
    218216                } else {
    219                         return Request.newAsyncRequest(corrId, methodName, arguments);
     217                        return Request.newAsyncRequest(corrId, methodName, arguments, multi);
    220218                }
    221219        }
    … …  
    237235                        }
    238236                        resp = serializer.deserializeResponse(results.get(corrId), type);
    239                         // Log.saveLog("Client-Deserialize", results.get(corrId));
    240237
    241238                        // Remove and indicate the key exists (a hashmap can contain a null

  • trunk/src/main/java/omq/common/broker/Broker.java

    r53 r54  
    176176                if (responseListener == null) {
    177177                        responseListener = new ResponseListener(this);
     178                        responseListener.start();
    178179                }
    179180                if (eventDispatcher == null) {
    180181                        eventDispatcher = new EventDispatcher(this);
     182                        eventDispatcher.start();
    181183                }
    182184        }
    … …  
    197199                byte[] bytesResponse = serializer.serialize(wrapper);
    198200                channel.basicPublish(UID, "", null, bytesResponse);
    199 
    200                 // Log.saveLog("Server-Serialize", bytesResponse);
    201201        }
    202202

  • trunk/src/main/java/omq/common/event/EventDispatcher.java

    r53 r54  
    5656                boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUES, "false"));
    5757                channel.queueDeclare(event_queue, durable, false, false, null);
     58                logger.info("EventDispatcher creating queue: " + event_queue + ", durable: " + durable);
    5859
    5960                // Declare a new consumer
    … …  
    7273        @Override
    7374        public void run() {
     75                logger.info("EventDispatcher started");
    7476                Delivery delivery;
    7577                Event event;
    … …  
    8486
    8587                                logger.info("Event received -> Topic: " + event.getTopic() + "CorrId: " + event.getCorrId());
    86                                 // Log.saveLog("Client-Deserialize", delivery.getBody());
    87 
    88                                 // long timeEnd = (new Date()).getTime();
    89                                 // Log.saveTimeSendRequestLog("Client-time-response",
    90                                 // event.getCorrId(), "Event!", timeEnd);
    9188
    9289                                // Dispatch it

  • trunk/src/main/java/omq/common/message/Request.java

    r44 r54  
    1515        private boolean async = false;
    1616
     17        private transient boolean multi;
    1718        private transient long timeout;
    1819        private transient int retries;
    … …  
    3435        }
    3536
     37        public Request(String id2, String method2, boolean b, Object[] params2, boolean multi2) {
     38                // TODO Auto-generated constructor stub
     39        }
     40
    3641        public static Request newSyncRequest(String id, String method, Object[] params) {
    3742                return new Request(id, method, false, params);
    … …  
    4550        }
    4651
    47         public static Request newAsyncRequest(String id, String method, Object[] params) {
    48                 return new Request(id, method, true, params);
     52        public static Request newAsyncRequest(String id, String method, Object[] params, boolean multi) {
     53                return new Request(id, method, true, params, multi);
    4954        }
    5055
    … …  
    97102        }
    98103
     104        public boolean isMulti() {
     105                return multi;
     106        }
     107
     108        public void setMulti(boolean multi) {
     109                this.multi = multi;
     110        }
    99111}

  • trunk/src/main/java/omq/server/InvocationThread.java

    r53 r54  
    4444                                // Deserialize the json
    4545                                Request request = serializer.deserializeRequest(serializerType, delivery.getBody(), obj);
    46                                 // Log.saveLog("Server-Deserialize", delivery.getBody());
    47 
    4846                                String methodName = request.getMethod();
    4947                                String requestID = request.getId();
    … …  
    7775                                        byte[] bytesResponse = serializer.serialize(serializerType, resp);
    7876                                        channel.basicPublish("", props.getReplyTo(), replyProps, bytesResponse);
    79 
    80                                         // Log.saveLog("Server-Serialize", bytesResponse);
     77                                        logger.debug("Publish sync response -> Object: " + obj.getRef() + ", method: " + methodName + " corrID: " + requestID + " replyTo: "
     78                                                        + props.getReplyTo());
    8179                                }
    8280

  • trunk/src/main/java/omq/server/RemoteObject.java

    r53 r54  
    3535
    3636        private static final long serialVersionUID = -1778953938739846450L;
     37        private static final String multi = "multi#";
    3738        private static final Logger logger = Logger.getLogger(RemoteObject.class.getName());
    3839
    … …  
    230231                logger.info("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue);
    231232                channel.exchangeDeclare(exchange, "direct");
     233                channel.exchangeDeclare(multi + exchange, "fanout");
    232234                channel.queueDeclare(queue, durable, false, false, null);
    233235                channel.queueBind(queue, exchange, routingKey);
     236                channel.queueBind(queue, multi + exchange, routingKey);
    234237
    235238                // Declare the event topic fanout

  • trunk/src/main/resources/log4j.xml

    r49 r54  
    66        <param name="Threshold" value="DEBUG" />
    77        <layout class="org.apache.log4j.PatternLayout">
    8             <param name="ConversionPattern" value="%d{[yyyy-MM-dd HH:mm:ss]} %-5p %c{1}:%L - %m%n" />
     8            <param name="ConversionPattern" value="%d{[yyyy-MM-dd HH:mm:ss]} %-5p %c:%L - %m%n" />
    99        </layout>
    1010    </appender>
    … …  
    2525       
    2626        <layout class="org.apache.log4j.PatternLayout">
    27             <param value="%d{[yyyy-MM-dd HH:mm:ss]} %-5p %c{1}:%L - %m%n" name="ConversionPattern"/>
     27            <param value="%d{[yyyy-MM-dd HH:mm:ss]} %-5p %c:%L - %m%n" name="ConversionPattern"/>
    2828        </layout>       
    2929    </appender>

  • 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.