Changeset 107 for branches/supervisor/src/main/java/omq/client/proxy/Proxymq.java

Timestamp:

10/19/13 13:20:44 (11 years ago)

Author:

stoda

Message:

Error detected: there should be only one thread listening to the multiexchange queue.
TODO: change this. Make refactor in the invocationthread. Change remotethreadpool to achieve this behavior.
AInvocationThread <- InvocationTHread

<- MultiInvocationTHread

File:

• branches/supervisor/src/main/java/omq/client/proxy/Proxymq.java (modified) (5 diffs)

branches/supervisor/src/main/java/omq/client/proxy/Proxymq.java

@@ -47 +47 @@
 
         private String reference;
+        private String UID;
         private transient String exchange;
         private transient String multiExchange;
@@ -72 +73 @@
          * Proxymq Constructor.
          * 
-         * This constructor uses an reference to know which object will call. It also uses
-         * Properties to set where to send the messages
+         * This constructor uses an reference to know which object will call. It
+         * also uses Properties to set where to send the messages
          * 
          * @param reference
-         *            The reference represents the unique identifier of a remote object
+         *            The reference represents the unique identifier of a remote
+         *            object
          * @param clazz
          *            It represents the real class of the remote object. With this
@@ -119 +121 @@
                                 return getRef();
                         }
+                        if (methodName.equals("getUID")) {
+                                return getUID();
+                        }
+                        if (methodName.equals("setUID")) {
+                                setUID((String) arguments[0]);
+                                return null;
+                        }
                         if (methodName.equals("equals")) {
                                 if (arguments[0] instanceof Remote) {
@@ -168 +177 @@
                 }
 
+                // TODO look this carefully
+                String appId = UID == null ? reference : UID;
+
                 // Add the correlation ID and create a replyTo property
-                BasicProperties props = new BasicProperties.Builder().appId(reference).correlationId(corrId).replyTo(replyQueueName).type(serializerType)
-                                .deliveryMode(deliveryMode).build();
+                BasicProperties props = new BasicProperties.Builder().appId(appId).correlationId(corrId).replyTo(replyQueueName)
+                                .type(serializerType).deliveryMode(deliveryMode).build();
 
                 // Publish the message
                 byte[] bytesRequest = serializer.serialize(serializerType, request);
                 broker.publishMessge(exchange, routingkey, props, bytesRequest);
-                logger.debug("Proxymq: " + reference + " invokes '" + request.getMethod() + "' , corrID: " + corrId + ", exchange: " + exchange + ", replyQueue: "
-                                + replyQueueName + ", serializerType: " + serializerType + ", multi call: " + request.isMulti() + ", async call: " + request.isAsync()
-                                + ", delivery mode: " + deliveryMode);
+                logger.debug("Proxymq: " + reference + " invokes '" + request.getMethod() + "' , corrID: " + corrId + ", exchange: " + exchange
+                                + ", replyQueue: " + replyQueueName + ", serializerType: " + serializerType + ", multi call: " + request.isMulti()
+                                + ", async call: " + request.isAsync() + ", delivery mode: " + deliveryMode);
         }
 
@@ -362 +374 @@
         }
 
+        @Override
+        public String getUID() {
+                return UID;
+        }
+
+        @Override
+        public void setUID(String uID) {
+                this.UID = uID;
+        }
+
 }