Changeset 99 for branches/supervisor/src/main/java/omq/client/proxy
- Timestamp:
- 10/08/13 12:41:19 (11 years ago)
- Location:
- branches/supervisor/src/main/java/omq/client/proxy
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/supervisor/src/main/java/omq/client/proxy/MultiProxymq.java
r83 r99 55 55 56 56 byte[] bytesRequest = serializer.serialize(serializerType, request); 57 broker. getChannel().basicPublish(exchange, routingkey, props, bytesRequest);57 broker.publishMessge(exchange, routingkey, props, bytesRequest); 58 58 59 59 logger.debug("Proxymq: " + uid + " invokes " + methodName + ", corrID" + corrId + ", exchange: " + exchange + ", replyQueue: " + replyQueueName -
branches/supervisor/src/main/java/omq/client/proxy/Proxymq.java
r92 r99 172 172 // Publish the message 173 173 byte[] bytesRequest = serializer.serialize(serializerType, request); 174 broker. getChannel().basicPublish(exchange, routingkey, props, bytesRequest);174 broker.publishMessge(exchange, routingkey, props, bytesRequest); 175 175 logger.debug("Proxymq: " + uid + " invokes '" + request.getMethod() + "' , corrID: " + corrId + ", exchange: " + exchange + ", replyQueue: " 176 176 + replyQueueName + ", serializerType: " + serializerType + ", multi call: " + request.isMulti() + ", async call: " + request.isAsync()
Note: See TracChangeset
for help on using the changeset viewer.