Changeset 98 for trunk/src/main/java/omq/client

Timestamp:

10/08/13 10:49:46 (11 years ago)

Author:

stoda

Message:

0.5.6
Synchronized channel and reopening when they are closed

Location:

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

Files:

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

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

@@ -55 +55 @@
 
                 byte[] bytesRequest = serializer.serialize(serializerType, request);
-                broker.getChannel().basicPublish(exchange, routingkey, props, bytesRequest);
+                broker.publishMessge(exchange, routingkey, props, bytesRequest);
 
                 logger.debug("Proxymq: " + uid + " invokes " + methodName + ", corrID" + corrId + ", exchange: " + exchange + ", replyQueue: " + replyQueueName

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

@@ -165 +165 @@
                 // Publish the message
                 byte[] bytesRequest = serializer.serialize(serializerType, request);
-                broker.getChannel().basicPublish(exchange, routingkey, props, bytesRequest);
+                broker.publishMessge(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()