Changeset 76 for trunk/src/main/java/omq
- Timestamp:
- 07/03/13 15:45:10 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/src/main/java/omq/client/proxy/Proxymq.java
r75 r76 119 119 // Publish the request 120 120 if (request.isAsync()) { 121 logger.debug("Publish async request -> " + request.getId());122 121 publishMessage(request, replyQueueName); 123 122 } else { 124 logger.debug("Publish sync request -> " + request.getId());125 123 response = publishSyncRequest(request, method.getReturnType()); 126 124 } … … 150 148 byte[] bytesRequest = serializer.serialize(serializerType, request); 151 149 broker.getChannel().basicPublish(exchange, routingkey, props, bytesRequest); 150 logger.debug("Proxymq: " + uid + " invokes " + request.getMethod() + ", corrID" + corrId + ", exchange: " + exchange + ", replyQueue: " 151 + replyQueueName + ", serializerType: " + serializerType + ", multi call: " + request.isMulti() + ", async call: " + request.isAsync()); 152 152 } 153 153
Note: See TracChangeset
for help on using the changeset viewer.