Changeset 58 for trunk/src/test/java/omq


Ignore:
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:
1 added
1 deleted
3 edited

Legend:

Unmodified
Added
Removed
  • trunk/src/test/java/omq/test/multiProcess/MultiProcessTest.java

    r57 r58  
    2121public class MultiProcessTest {
    2222        public static Broker broker;
    23         public static Number remoteNumber;
     23        public static NumberClient remoteNumber;
    2424
    2525        public MultiProcessTest(String type) throws Exception {
     
    4444
    4545                broker = new Broker(env);
    46                 remoteNumber = broker.lookup("number", Number.class);
     46                remoteNumber = broker.lookup("number", NumberClient.class);
    4747        }
    4848
     
    8585                int x = 10;
    8686                remoteNumber.setNumber(x);
    87                 int a = remoteNumber.getNumer();
     87                int a = remoteNumber.getNumber();
    8888                assertEquals(0, a);
    89                 int b = remoteNumber.getNumer();
     89                int b = remoteNumber.getNumber();
    9090                assertEquals(x, b);
    9191                remoteNumber.setNumber(0);
     
    9898                remoteNumber.setMultiNumber(x);
    9999                Thread.sleep(200);
    100                 int a = remoteNumber.getNumer();
    101                 int b = remoteNumber.getNumer();
     100                int a = remoteNumber.getNumber();
     101                int b = remoteNumber.getNumber();
    102102                assertEquals(x, a);
    103103                assertEquals(x, b);
     104                int[] number = remoteNumber.getMultiNumber();
     105                assertEquals(x, number[0]);
     106                assertEquals(x, number[1]);
    104107                remoteNumber.setMultiNumber(0);
    105108                Thread.sleep(200);
  • trunk/src/test/java/omq/test/multiProcess/Number.java

    r54 r58  
    22
    33import omq.Remote;
    4 import omq.client.annotation.AsyncMethod;
    5 import omq.client.annotation.MultiMethod;
    6 import omq.client.annotation.RemoteInterface;
    7 import omq.client.annotation.SyncMethod;
    84
    9 @RemoteInterface
    105public interface Number extends Remote {
    11         @SyncMethod(timeout = 1000)
    126        public void setNumber(int x);
    137
    14         @SyncMethod(timeout = 1000)
    15         public int getNumer();
     8        public int getNumber();
    169
    17         @MultiMethod
    18         @AsyncMethod
    1910        public void setMultiNumber(int x);
     11
     12        public int getMultiNumber();
    2013}
  • trunk/src/test/java/omq/test/multiProcess/NumberImpl.java

    r54 r58  
    11package omq.test.multiProcess;
    22
    3 import omq.client.annotation.AsyncMethod;
    4 import omq.client.annotation.MultiMethod;
    5 import omq.client.annotation.SyncMethod;
    63import omq.server.RemoteObject;
    74
     
    2017        }
    2118
    22         @Override
    23         @SyncMethod
    2419        public void setNumber(int x) {
    2520                this.x = x;
    2621        }
    2722
    28         @Override
    29         @SyncMethod(timeout = 1000)
    30         public int getNumer() {
     23        public int getNumber() {
    3124                return x;
    3225        }
    3326
    34         @Override
    35         @MultiMethod
    36         @AsyncMethod
    3727        public void setMultiNumber(int x) {
    3828                this.x = x;
    3929        }
    4030
     31        public int getMultiNumber() {
     32                return x;
     33        }
     34
    4135}
Note: See TracChangeset for help on using the changeset viewer.