- Timestamp:
- 05/22/13 18:41:56 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/objectmq/src/omq/ztest/calculator/CalculatorTest.java
r16 r17 24 24 env.setProperty(ParameterQueue.SERVER_HOST, "127.0.0.1"); 25 25 env.setProperty(ParameterQueue.SERVER_PORT, "5672"); 26 // env.setProperty(ParameterQueue.SERIALIZERNAME, "omq.common.util.Serializers.KryoImp"); 26 // env.setProperty(ParameterQueue.SERIALIZERNAME, 27 // "omq.common.util.Serializers.KryoImp"); 27 28 env.setProperty(ParameterQueue.SERIALIZERNAME, "omq.common.util.Serializers.GsonImp"); 28 29 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false"); … … 82 83 Thread.sleep(200); 83 84 } 85 86 @Test 87 public void sendMessage() throws Exception { 88 Message m = new Message(2334, "Hello objectmq"); 89 remoteCalc.sendMessage(m); 90 } 84 91 }
Note: See TracChangeset
for help on using the changeset viewer.