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

Timestamp:

07/04/13 16:45:14 (11 years ago)

Author:

stoda

Message:

ParameterQueues? changed, added some properties to modify the queues

Location:

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

Files:

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

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

@@ -41 +41 @@
                 replyQueueName = env.getProperty(ParameterQueue.RPC_REPLY_QUEUE);
                 exchange = multi + uid;
-                serializerType = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.JAVA);
+                serializerType = env.getProperty(ParameterQueue.PROXY_SERIALIZER, Serializer.JAVA);
         }
 

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

@@ -51 +51 @@
         private transient Serializer serializer;
         private transient Properties env;
+        private transient Integer deliveryMode = null;
         private transient Map<String, byte[]> results;
 
@@ -94 +95 @@
 
                 // set the serializer type
-                serializerType = env.getProperty(ParameterQueue.SERIALIZER_NAME, Serializer.JAVA);
+                serializerType = env.getProperty(ParameterQueue.PROXY_SERIALIZER, Serializer.JAVA);
+                if (env.getProperty(ParameterQueue.DELIVERY_MODE) != null) {
+                        deliveryMode = Integer.parseInt(env.getProperty(ParameterQueue.DELIVERY_MODE));
+                }
 
                 // Create a new hashmap and registry it in rListener
@@ -143 +147 @@
 
                 // Add the correlation ID and create a replyTo property
-                BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).replyTo(replyQueueName).type(serializerType).build();
+                BasicProperties props = new BasicProperties.Builder().appId(uid).correlationId(corrId).replyTo(replyQueueName).type(serializerType)
+                                .deliveryMode(deliveryMode).build();
 
                 // Publish the message
                 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());
+                logger.debug("Proxymq: " + uid + " invokes '" + request.getMethod() + "' , corrID: " + corrId + ", exchange: " + exchange + ", replyQueue: "
+                                + replyQueueName + ", serializerType: " + serializerType + ", multi call: " + request.isMulti() + ", async call: " + request.isAsync()
+                                + ", delivery mode: " + deliveryMode);
         }