Changeset 29

Timestamp:

05/30/13 12:47:17 (11 years ago)

Author:

stoda

Message:

Singleton didn't worked in parallel threads solved adding synchronized.
Num threads by property added.
Example with different threads added.

Location:

trunk/objectmq

Files:

• src/omq/common/broker/Broker.java (modified) (1 diff)
• src/omq/server/remote/request/RemoteObject.java (modified) (1 diff)
• src/omq/server/remote/request/RemoteWrapper.java (modified) (1 diff)
• test/test2/Car.java (modified) (2 diffs)
• test/test2/CarImpl.java (modified) (3 diffs)
• test/test2/CarThread.java (added)
• test/test2/ClientTest.java (added)
• test/test2/Mobile.java (added)
• test/test2/MobileImpl.java (added)
• test/test2/MobileThread.java (added)
• test/test2/ServerTest.java (added)

trunk/objectmq/src/omq/common/broker/Broker.java

@@ -101 +101 @@
         }
 
-        private static void initClient(Properties environment) throws Exception {
+        private static synchronized void initClient(Properties environment) throws Exception {
                 if (ResponseListener.isVoid()) {
                         ResponseListener.init(environment);

trunk/objectmq/src/omq/server/remote/request/RemoteObject.java

@@ -71 +71 @@
 
                 // Get num threads to use
-                int numThreads = 4;// Integer.parseInt(env.getProperty(ParameterQueue.NUM_THREADS));
+                int numThreads = Integer.parseInt(env.getProperty(ParameterQueue.NUM_THREADS, "1"));
                 remoteWrapper = new RemoteWrapper(this, numThreads);
 

trunk/objectmq/src/omq/server/remote/request/RemoteWrapper.java

@@ -24 +24 @@
                 invocationList = new ArrayList<InvocationThread>();
                 deliveryQueue = new LinkedBlockingDeque<QueueingConsumer.Delivery>();
+
+                System.out.println("RemoteWrapper -> Object: " + obj.getRef() + ", numthreads listening = " + numThreads);
+
                 for (int i = 0; i < numThreads; i++) {
                         InvocationThread thread = new InvocationThread(obj, deliveryQueue);

trunk/objectmq/test/test2/Car.java

@@ -7 +7 @@
 import omq.client.annotation.RemoteInterface;
 import omq.client.annotation.SyncMethod;
+import omq.exception.RemoteException;
 
 @RemoteInterface
@@ -28 +29 @@
         public List<Rim> getRims();
 
+        @AsyncMethod
+        public void setMobile(String mobile) throws RemoteException;
+
+        @SyncMethod
+        public String getMobile();
+
 }

trunk/objectmq/test/test2/CarImpl.java

@@ -3 +3 @@
 import java.util.List;
 
+import omq.common.broker.Broker;
+import omq.exception.RemoteException;
 import omq.server.remote.request.RemoteObject;
 
@@ -14 +16 @@
         private int hp;
         private List<Rim> rims;
+        private Mobile mobile;
 
         @Override
@@ -27 +30 @@
         @Override
         public void setHP(int hp) {
-        
+                this.hp = hp;
         }
 
         @Override
         public int getHP() {
-                // TODO Auto-generated method stub
-                return 0;
+                return hp;
         }
 
         @Override
         public void setRims(List<Rim> rims) {
-                // TODO Auto-generated method stub
-
+                this.rims = rims;
         }
 
         @Override
         public List<Rim> getRims() {
-                // TODO Auto-generated method stub
-                return null;
+                return rims;
         }
+
+        @Override
+        public void setMobile(String mobile) throws RemoteException {
+                this.mobile = (Mobile) Broker.lookup(mobile, Mobile.class);
+        }
+
+        @Override
+        public String getMobile() {
+                return mobile.getRef();
+        }
+
 }