Changeset 58 for trunk/src/test

Timestamp:

06/25/13 16:38:31 (11 years ago)

Author:

stoda

Message:

@MultiMethod? + @SyncMethod? implemented and tested

Location:

trunk/src/test/java/omq/test

Files:

• multiProcess/MultiProcessTest.java (modified) (4 diffs)
• multiProcess/Number.java (modified) (1 diff)
• multiProcess/NumberClient.java (added)
• multiProcess/NumberImpl.java (modified) (2 diffs)
• multiThread (deleted)

trunk/src/test/java/omq/test/multiProcess/MultiProcessTest.java

@@ -21 +21 @@
 public class MultiProcessTest {
         public static Broker broker;
-        public static Number remoteNumber;
+        public static NumberClient remoteNumber;
 
         public MultiProcessTest(String type) throws Exception {
@@ -44 +44 @@
 
                 broker = new Broker(env);
-                remoteNumber = broker.lookup("number", Number.class);
+                remoteNumber = broker.lookup("number", NumberClient.class);
         }
 
@@ -85 +85 @@
                 int x = 10;
                 remoteNumber.setNumber(x);
-                int a = remoteNumber.getNumer();
+                int a = remoteNumber.getNumber();
                 assertEquals(0, a);
-                int b = remoteNumber.getNumer();
+                int b = remoteNumber.getNumber();
                 assertEquals(x, b);
                 remoteNumber.setNumber(0);
@@ -98 +98 @@
                 remoteNumber.setMultiNumber(x);
                 Thread.sleep(200);
-                int a = remoteNumber.getNumer();
-                int b = remoteNumber.getNumer();
+                int a = remoteNumber.getNumber();
+                int b = remoteNumber.getNumber();
                 assertEquals(x, a);
                 assertEquals(x, b);
+                int[] number = remoteNumber.getMultiNumber();
+                assertEquals(x, number[0]);
+                assertEquals(x, number[1]);
                 remoteNumber.setMultiNumber(0);
                 Thread.sleep(200);

trunk/src/test/java/omq/test/multiProcess/Number.java

@@ -2 +2 @@
 
 import omq.Remote;
-import omq.client.annotation.AsyncMethod;
-import omq.client.annotation.MultiMethod;
-import omq.client.annotation.RemoteInterface;
-import omq.client.annotation.SyncMethod;
 
-@RemoteInterface
 public interface Number extends Remote {
-        @SyncMethod(timeout = 1000)
         public void setNumber(int x);
 
-        @SyncMethod(timeout = 1000)
-        public int getNumer();
+        public int getNumber();
 
-        @MultiMethod
-        @AsyncMethod
         public void setMultiNumber(int x);
+
+        public int getMultiNumber();
 }

trunk/src/test/java/omq/test/multiProcess/NumberImpl.java

@@ -1 +1 @@
 package omq.test.multiProcess;
 
-import omq.client.annotation.AsyncMethod;
-import omq.client.annotation.MultiMethod;
-import omq.client.annotation.SyncMethod;
 import omq.server.RemoteObject;
 
@@ -20 +17 @@
         }
 
-        @Override
-        @SyncMethod
         public void setNumber(int x) {
                 this.x = x;
         }
 
-        @Override
-        @SyncMethod(timeout = 1000)
-        public int getNumer() {
+        public int getNumber() {
                 return x;
         }
 
-        @Override
-        @MultiMethod
-        @AsyncMethod
         public void setMultiNumber(int x) {
                 this.x = x;
         }
 
+        public int getMultiNumber() {
+                return x;
+        }
+
 }