Changeset 15 for trunk/objectmq/src/omq/ztest/calculator/CalculatorTest.java

Timestamp:

05/20/13 19:45:19 (11 years ago)

Author:

stoda

Message:

Listeners added (not tested)
little test to shut up Vilella

File:

• trunk/objectmq/src/omq/ztest/calculator/CalculatorTest.java (modified) (5 diffs)

trunk/objectmq/src/omq/ztest/calculator/CalculatorTest.java

@@ -12 +12 @@
 
 public class CalculatorTest {
-        private static CalculatorImpl calc;
         private static Calculator remoteCalc;
-
-        @BeforeClass
-        public static void startServer() throws Exception {
-                Properties env = new Properties();
-                env.setProperty(ParameterQueue.USER_NAME, "guest");
-                env.setProperty(ParameterQueue.USER_PASS, "guest");
-
-                // Get host info of rabbimq (where it is)
-                env.setProperty(ParameterQueue.SERVER_HOST, "10.30.239.228");
-                env.setProperty(ParameterQueue.SERVER_PORT, "5672");
-                env.setProperty(ParameterQueue.SERIALIZERNAME, "omq.common.util.Serializers.KryoImp");
-                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "true");
-
-                // Get info about the queue & the exchange where the RemoteListener will
-                // listen to.
-                env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
-                env.setProperty(ParameterQueue.RPC_QUEUE, "rpc_queue");
-                env.setProperty(ParameterQueue.RPC_ROUTING_KEY, "rpc");
-
-                calc = new CalculatorImpl();
-
-                Broker.initBroker(env);
-                Broker.bind(Calculator.class.getSimpleName(), calc);
-        }
+        private static Calculator remoteCalc2;
 
         @BeforeClass
@@ -46 +22 @@
 
                 // Set host info of rabbimq (where it is)
-                env.setProperty(ParameterQueue.SERVER_HOST, "10.30.239.228");
+                env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
                 env.setProperty(ParameterQueue.SERIALIZERNAME, "omq.common.util.Serializers.KryoImp");
-                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "true");
-                
+                env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
+
                 // Set info about where the message will be sent
                 env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
-                env.setProperty(ParameterQueue.RPC_ROUTING_KEY, "rpc");
 
                 // Set info about the queue & the exchange where the ResponseListener
@@ -61 +36 @@
 
                 Broker.initBroker(env);
-                remoteCalc = (Calculator) Broker.lookup(Calculator.class.getSimpleName(), Calculator.class);
+                remoteCalc = (Calculator) Broker.lookup("calculator1", Calculator.class);
+                remoteCalc2 = (Calculator) Broker.lookup("calculator2", Calculator.class);
         }
 
@@ -76 +52 @@
 
         @Test
+        public void add2() throws Exception {
+                int x = 10;
+                int y = 20;
+
+                int sync = remoteCalc2.add(x, y);
+                int sum = x + y;
+
+                assertEquals(sum, sync);
+        }
+
+        @Test
         public void mult() throws Exception {
                 int x = 5;
@@ -82 +69 @@
                 remoteCalc.mult(x, y);
                 Thread.sleep(200);
-
-                int mult = x * y;
-
-                assertEquals(mult, calc.getMult());
         }
 }