Changeset 105 for branches/supervisor/src/main/java/omq/client/proxy/MultiProxymq.java

Timestamp:

10/16/13 16:19:02 (11 years ago)

Author:

stoda

Message:

UID changed to reference
TODO: add UID

File:

• branches/supervisor/src/main/java/omq/client/proxy/MultiProxymq.java (modified) (3 diffs)

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

@@ -25 +25 @@
         private static final String multi = "multi#";
 
-        private String uid;
+        private String reference;
         private Broker broker;
         private Serializer serializer;
@@ -33 +33 @@
         private transient String serializerType;
 
-        public MultiProxymq(String uid, Class<?> clazz, Broker broker) throws Exception {
-                this.uid = uid;
+        public MultiProxymq(String reference, Class<?> clazz, Broker broker) throws Exception {
+                this.reference = reference;
                 this.broker = broker;
                 serializer = broker.getSerializer();
 
                 Properties env = broker.getEnvironment();
-                exchange = multi + uid;
+                exchange = multi + reference;
                 serializerType = env.getProperty(ParameterQueue.PROXY_SERIALIZER, Serializer.JAVA);
         }
@@ -52 +52 @@
 
                 // Add the correlation ID and create a replyTo property
-                BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).type(serializerType).build();
+                BasicProperties props = new BasicProperties.Builder().appId(reference).correlationId(corrId).type(serializerType).build();
 
                 byte[] bytesRequest = serializer.serialize(serializerType, request);
                 broker.publishMessge(exchange, routingkey, props, bytesRequest);
 
-                logger.debug("Proxymq: " + uid + " invokes " + methodName + ", corrID" + corrId + ", exchange: " + exchange + ", replyQueue: " + replyQueueName
+                logger.debug("Proxymq: " + reference + " invokes " + methodName + ", corrID" + corrId + ", exchange: " + exchange + ", replyQueue: " + replyQueueName
                                 + ", serializerType: " + serializerType + ", multi call: " + request.isMulti() + ", async call: " + request.isAsync());