Changeset 76 for trunk/src/main/java/omq/client/proxy/Proxymq.java

Timestamp:

07/03/13 15:45:10 (11 years ago)

Author:

stoda

Message:

some loggers changed

File:

• trunk/src/main/java/omq/client/proxy/Proxymq.java (modified) (2 diffs)

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

@@ -119 +119 @@
                 // Publish the request
                 if (request.isAsync()) {
-                        logger.debug("Publish async request -> " + request.getId());
                         publishMessage(request, replyQueueName);
                 } else {
-                        logger.debug("Publish sync request -> " + request.getId());
                         response = publishSyncRequest(request, method.getReturnType());
                 }
@@ -150 +148 @@
                 byte[] bytesRequest = serializer.serialize(serializerType, request);
                 broker.getChannel().basicPublish(exchange, routingkey, props, bytesRequest);
+                logger.debug("Proxymq: " + uid + " invokes " + request.getMethod() + ", corrID" + corrId + ", exchange: " + exchange + ", replyQueue: "
+                                + replyQueueName + ", serializerType: " + serializerType + ", multi call: " + request.isMulti() + ", async call: " + request.isAsync());
         }