Changeset 53 for trunk/src/main/java/omq/server/InvocationThread.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/InvocationThread.java (modified) (3 diffs)

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

@@ -23 +23 @@
         private static final Logger logger = Logger.getLogger(InvocationThread.class.getName());
         private RemoteObject obj;
+        private transient Serializer serializer;
         private BlockingQueue<Delivery> deliveryQueue;
         private boolean killed = false;
 
-        public InvocationThread(RemoteObject obj, BlockingQueue<Delivery> deliveryQueue) {
+        public InvocationThread(RemoteObject obj, BlockingQueue<Delivery> deliveryQueue, Serializer serializer) {
                 this.obj = obj;
                 this.deliveryQueue = deliveryQueue;
+                this.serializer = serializer;
         }
 
@@ -41 +43 @@
 
                                 // Deserialize the json
-                                Request request = Serializer.deserializeRequest(serializerType, delivery.getBody(), obj);
+                                Request request = serializer.deserializeRequest(serializerType, delivery.getBody(), obj);
                                 // Log.saveLog("Server-Deserialize", delivery.getBody());
 
@@ -73 +75 @@
                                         BasicProperties replyProps = new BasicProperties.Builder().appId(obj.getRef()).correlationId(props.getCorrelationId()).build();
 
-                                        byte[] bytesResponse = Serializer.serialize(serializerType, resp);
+                                        byte[] bytesResponse = serializer.serialize(serializerType, resp);
                                         channel.basicPublish("", props.getReplyTo(), replyProps, bytesResponse);