Changeset 53 for trunk/src/main/java/omq/server/RemoteWrapper.java

Timestamp:

06/20/13 16:57:39 (11 years ago)

Author:

stoda

Message:

Non static broker
TODO: change all test to see whether the new broker configuration works

File:

• trunk/src/main/java/omq/server/RemoteWrapper.java (modified) (3 diffs)

trunk/src/main/java/omq/server/RemoteWrapper.java

@@ -4 +4 @@
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.LinkedBlockingDeque;
+
+import omq.common.util.Serializer;
 
 import org.apache.log4j.Logger;
@@ -23 +25 @@
         private BlockingQueue<Delivery> deliveryQueue;
 
-        public RemoteWrapper(RemoteObject obj, int numThreads) {
+        public RemoteWrapper(RemoteObject obj, int numThreads, Serializer serializer) {
                 this.obj = obj;
                 this.numThreads = numThreads;
@@ -32 +34 @@
 
                 for (int i = 0; i < numThreads; i++) {
-                        InvocationThread thread = new InvocationThread(obj, deliveryQueue);
+                        InvocationThread thread = new InvocationThread(obj, deliveryQueue, serializer);
                         invocationList.add(thread);
                         thread.start();