Changeset 77 for trunk/src/main/java/omq/server/RemoteObject.java

Timestamp:

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

Author:

stoda

Message:

ParameterQueues? changed, added some properties to modify the queues

File:

• trunk/src/main/java/omq/server/RemoteObject.java (modified) (2 diffs)

trunk/src/main/java/omq/server/RemoteObject.java

@@ -218 +218 @@
                 String queue = UID;
                 String routingKey = UID;
+
                 // Multi info
                 String multiExchange = multi + UID;
+                if (env.getProperty(ParameterQueue.MULTI_QUEUE_NAME) != null) {
+                        multiQueue = env.getProperty(ParameterQueue.MULTI_QUEUE_NAME);
+                }
 
                 boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUES, "false"));
+                boolean exclusive = Boolean.parseBoolean(env.getProperty(ParameterQueue.EXCLUSIVE_QUEUE, "false"));
+                boolean autoDelete = Boolean.parseBoolean(env.getProperty(ParameterQueue.AUTO_DELETE_QUEUE, "false"));
 
                 // Start channel
@@ -227 +233 @@
 
                 // Declares and bindings
-                logger.info("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue + ", Durable: " + durable);
+                logger.info("RemoteObject: " + UID + " declaring direct exchange: " + exchange + ", Queue: " + queue + ", Durable: " + durable + ", Exclusive: "
+                                + exclusive + ", AutoDelete: " + autoDelete);
                 channel.exchangeDeclare(exchange, "direct");
-                channel.queueDeclare(queue, durable, false, false, null);
+                channel.queueDeclare(queue, durable, exclusive, autoDelete, null);
                 channel.queueBind(queue, exchange, routingKey);
 
-                logger.info("RemoteObject: " + UID + " declaring fanout exchange: " + multiExchange + ", Queue: " + multiQueue + ", Durable: " + durable);
+                logger.info("RemoteObject: " + UID + " declaring fanout exchange: " + multiExchange + ", Queue: " + multiQueue + ", Durable: " + durable
+                                + ", Exclusive: " + exclusive + ", AutoDelete: " + autoDelete);
                 channel.exchangeDeclare(multiExchange, "fanout");
-                channel.queueDeclare(multiQueue, durable, false, false, null);
+                channel.queueDeclare(multiQueue, durable, exclusive, autoDelete, null);
                 channel.queueBind(multiQueue, multiExchange, "");