Changeset 11 for trunk/objectmq/src/omq/ztest

Timestamp:

05/17/13 15:41:11 (12 years ago)

Author:

gguerrero

Message:

Fixed dynamic Serializer (by default is JavaImp?).
Added compression parameter (by default is false).

File:

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

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

@@ -22 +22 @@
 
                 // Get host info of rabbimq (where it is)
-                env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
+                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
@@ -44 +46 @@
 
                 // Set host info of rabbimq (where it is)
-                env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1");
+                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");
+                
                 // Set info about where the message will be sent
                 env.setProperty(ParameterQueue.RPC_EXCHANGE, "rpc_exchange");
@@ -57 +61 @@
 
                 Broker.initBroker(env);
-
                 remoteCalc = (Calculator) Broker.lookup(Calculator.class.getSimpleName(), Calculator.class);
         }