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

Timestamp:

07/10/13 13:14:30 (11 years ago)

Author:

stoda

Message:

Default queues added, default exchange enabled, more control in remote queues added.
Tests verified and changed Persistent test to show how to make persistent messages.

Location:

trunk/src/main/java/omq/client

Files:

• listener/ResponseListener.java (modified) (2 diffs)
• proxy/Proxymq.java (modified) (1 diff)

trunk/src/main/java/omq/client/listener/ResponseListener.java

@@ -120 +120 @@
 
                 String reply_queue = env.getProperty(ParameterQueue.RPC_REPLY_QUEUE);
-                boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUES, "false"));
+                boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUE, "false"));
+                boolean exclusive = Boolean.parseBoolean(env.getProperty(ParameterQueue.EXCLUSIVE_QUEUE, "true"));
+                boolean autoDelete = Boolean.parseBoolean(env.getProperty(ParameterQueue.AUTO_DELETE_QUEUE, "true"));
 
                 int ttl = Integer.parseInt(env.getProperty(ParameterQueue.MESSAGE_TTL_IN_QUEUES, "-1"));
@@ -128 +130 @@
                 }
 
-                channel.queueDeclare(reply_queue, durable, false, false, args);
-                logger.info("ResponseListener creating queue: " + reply_queue + ", durable: " + durable + "TTL: " + (ttl > 0 ? ttl : "not set"));
+                if (reply_queue == null) {
+                        reply_queue = channel.queueDeclare().getQueue();
+                        env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, reply_queue);
+                } else {
+                        channel.queueDeclare(reply_queue, durable, exclusive, autoDelete, args);
+                }
+                logger.info("ResponseListener creating queue: " + reply_queue + ", durable: " + durable + ", exclusive: " + exclusive + ", autoDelete: " + autoDelete
+                                + ", TTL: " + (ttl > 0 ? ttl : "not set"));
 
                 // Declare a new consumer

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

@@ -92 +92 @@
                 // this.channel = Broker.getChannel();
                 env = broker.getEnvironment();
-                exchange = env.getProperty(ParameterQueue.RPC_EXCHANGE);
+                exchange = env.getProperty(ParameterQueue.RPC_EXCHANGE, "");
                 multiExchange = multi + uid;
                 replyQueueName = env.getProperty(ParameterQueue.RPC_REPLY_QUEUE);