Changeset 106 for branches/supervisor/src/main/java/omq/server/InvocationThread.java

Timestamp:

10/18/13 16:09:36 (11 years ago)

Author:

stoda

Message:

abans que la segueixi liant...

File:

• branches/supervisor/src/main/java/omq/server/InvocationThread.java (modified) (5 diffs)

branches/supervisor/src/main/java/omq/server/InvocationThread.java

@@ -36 +36 @@
         private RemoteObject obj;
         private String reference;
+        private String UID;
         private Properties env;
         private boolean idle;
@@ -54 +55 @@
         public InvocationThread(RemoteObject obj) throws Exception {
                 this.obj = obj;
+                this.UID = obj.getUID();
                 this.reference = obj.getRef();
                 this.env = obj.getEnv();
@@ -87 +89 @@
                                 String serializerType = delivery.getProperties().getType();
 
-                                // Deserialize the json
+                                // Deserialize the request
                                 Request request = serializer.deserializeRequest(serializerType, delivery.getBody(), obj);
                                 String methodName = request.getMethod();
@@ -196 +198 @@
 
                 /*
+                 * UID queue
+                 */
+
+                if (UID != null) {
+
+                        boolean uidDurable = false;
+                        boolean uidExclusive = true;
+                        boolean uidAutoDelete = true;
+
+                        channel.queueDeclare(UID, uidDurable, uidExclusive, uidAutoDelete, null);
+                        if (!exchange.equalsIgnoreCase("")) { // Default exchange case
+                                channel.queueBind(UID, exchange, UID);
+                        }
+                }
+
+                /*
                  * Multi queue, exclusive per each instance
                  */
@@ -233 +251 @@
                 channel.basicConsume(queue, autoAck, consumer);
                 channel.basicConsume(multiQueue, autoAck, consumer);
+                if (UID != null) {
+                        channel.basicConsume(UID, autoAck, consumer);
+                }
         }