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

Timestamp:

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

Author:

stoda

Message:

abans que la segueixi liant...

Location:

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

Files:

• InvocationThread.java (modified) (5 diffs)
• RemoteObject.java (modified) (3 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);
+                }
         }
 

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

@@ -31 +31 @@
 
         private String reference;
+        private String UID;
         private Properties env;
         private transient Broker broker;
@@ -83 +84 @@
                 pool = new RemoteThreadPool(minPoolThreads, maxPoolThreads, refresh, keepAliveTime, maxMessagesPerThread, this, broker);
                 pool.start();
+        }
+
+        public void startRemoteObject(String reference, String UID, Broker broker, Properties env) throws Exception {
+                this.UID = UID;
+                startRemoteObject(reference, broker, env);
         }
 
@@ -209 +215 @@
         }
 
+        public String getUID() {
+                return UID;
+        }
+
+        public void setUID(String uID) {
+                UID = uID;
+        }
+
 }