Changeset 38 for trunk/objectmq/test

Timestamp:

06/13/13 17:19:52 (12 years ago)

Author:

stoda

Message:

Remote exception added
todo: change throws Exception to Throwable since it seems that NoSuchMethodException? does not inherit from Exception...

Location:

trunk/objectmq/test

Files:

• calculatorTest/Calculator.java (modified) (1 diff)
• calculatorTest/CalculatorImpl.java (modified) (4 diffs)
• calculatorTest/ClientTest.java (modified) (3 diffs)
• calculatorTest/ServerTest.java (modified) (1 diff)
• exceptionTest (added)
• exceptionTest/ClientInterface.java (added)
• exceptionTest/ClientTest.java (added)
• exceptionTest/OmqServerImpl.java (added)
• exceptionTest/ServerInterface.java (added)
• exceptionTest/ServerTest.java (added)
• exceptionTest/Trailer.java (added)

trunk/objectmq/test/calculatorTest/Calculator.java

@@ -21 +21 @@
 
         @AsyncMethod
-        public void divideByZero() throws IOException, SerializerException;
+        public void asyncDivideByZero() throws IOException, SerializerException;
+
+        @SyncMethod
+        public int divideByZero();
 
 }

trunk/objectmq/test/calculatorTest/CalculatorImpl.java

@@ -3 +3 @@
 import java.io.IOException;
 
-import omq.client.annotation.AsyncMethod;
 import omq.common.broker.Broker;
 import omq.exception.SerializerException;
@@ -17 +16 @@
         private static final long serialVersionUID = 1L;
 
+        @Override
         public int add(int x, int y) {
                 return x + y;
         }
 
+        @Override
         public void mult(int x, int y) {
                 mult = x * y;
@@ -33 +34 @@
         }
 
-        public void divideByZero() throws IOException, SerializerException {
+        @Override
+        public void asyncDivideByZero() throws IOException, SerializerException {
                 ZeroEvent ze = new ZeroEvent("my zero event", "zero-event");
                 Broker.trigger(ze);
@@ -40 +42 @@
 
         @Override
-        @AsyncMethod
         public void sendMessage(Message m) {
                 System.out.println("Code = "+m.getCode());
                 System.out.println("Message = "+m.getMessage());
         }
-        
-        
+
+        @Override
+        public int divideByZero() {
+                int x = 2 / 0;
+                return x;
+        }
 
 }

trunk/objectmq/test/calculatorTest/ClientTest.java

@@ -26 +26 @@
                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "false");
-                env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.kryo);
+                env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");
 
@@ -80 +80 @@
                 remoteCalc.addListener(zL);
 
-                remoteCalc.divideByZero();
+                remoteCalc.asyncDivideByZero();
 
                 Thread.sleep(200);
@@ -90 +90 @@
                 remoteCalc.sendMessage(m);
         }
+
+        @Test(expected = ArithmeticException.class)
+        public void divideByZero() {
+                remoteCalc.divideByZero();
+        }
 }

trunk/objectmq/test/calculatorTest/ServerTest.java

@@ -20 +20 @@
                 env.setProperty(ParameterQueue.SERVER_PORT, "5672");
                 env.setProperty(ParameterQueue.DURABLE_QUEUES, "true");
-                env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.kryo);
+                env.setProperty(ParameterQueue.SERIALIZER_NAME, Serializer.java);
                 env.setProperty(ParameterQueue.ENABLECOMPRESSION, "false");