Changeset 75 for trunk/src/main/java/omq/client/proxy

Timestamp:

07/02/13 11:50:11 (11 years ago)

Author:

stoda

Message:

Multi problem solved

Location:

trunk/src/main/java/omq/client/proxy

Files:

• MultiProxymq.java (modified) (4 diffs)
• Proxymq.java (modified) (1 diff)

trunk/src/main/java/omq/client/proxy/MultiProxymq.java

@@ -4 +4 @@
 import java.lang.reflect.Method;
 import java.util.Properties;
+
+import org.apache.log4j.Logger;
 
 import com.rabbitmq.client.AMQP.BasicProperties;
@@ -20 +22 @@
  */
 public class MultiProxymq implements InvocationHandler {
+        private static final Logger logger = Logger.getLogger(MultiProxymq.class.getName());
         private static final String multi = "multi#";
 
@@ -37 +40 @@
                 Properties env = broker.getEnvironment();
                 replyQueueName = env.getProperty(ParameterQueue.RPC_REPLY_QUEUE);
-                exchange = multi + env.getProperty(ParameterQueue.RPC_EXCHANGE);
+                exchange = multi + uid;
                 serializerType = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.JAVA);
         }
@@ -55 +58 @@
                 broker.getChannel().basicPublish(exchange, routingkey, props, bytesRequest);
 
+                logger.debug("Proxymq: " + uid + " invokes " + methodName + ", corrID" + corrId + ", exchange: " + exchange + ", replyQueue: " + replyQueueName
+                                + ", serializerType: " + serializerType + ", multi call: " + request.isMulti() + ", async call: " + request.isAsync());
+
                 return null;
         }

trunk/src/main/java/omq/client/proxy/Proxymq.java

@@ -90 +90 @@
                 env = broker.getEnvironment();
                 exchange = env.getProperty(ParameterQueue.RPC_EXCHANGE);
-                multiExchange = multi + exchange;
+                multiExchange = multi + uid;
                 replyQueueName = env.getProperty(ParameterQueue.RPC_REPLY_QUEUE);