Changeset 84 for trunk/src/main/java/omq/common/util

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.

File:

• trunk/src/main/java/omq/common/util/ParameterQueue.java (modified) (4 diffs)

trunk/src/main/java/omq/common/util/ParameterQueue.java

@@ -9 +9 @@
 public class ParameterQueue {
 
-        /**
-         * Set the proxy's serializer method
+        /*
+         * Connection info
          */
-        public static String PROXY_SERIALIZER = "omq.serializer";
 
         /**
-         * Set whether the messages must be compressed or not
+         * Set the clients username
          */
-        public static String ENABLE_COMPRESSION = "omq.compression";
+        public static String USER_NAME = "omq.username";
+
+        /**
+         * Set the clients password
+         */
+        public static String USER_PASS = "omq.pass";
 
         /**
@@ -30 +34 @@
 
         /**
-         * Set the clients username
+         * Set if the system will use ssl
          */
-        public static String USER_NAME = "omq.username";
+        public static String ENABLE_SSL = "omq.enable_ssl";
 
         /**
-         * Set the clients password
+         * Set how many time we have to wait to retry the connection with the server
+         * when this goes down
          */
-        public static String USER_PASS = "omq.pass";
+        public static String RETRY_TIME_CONNECTION = "omq.retry_connection";
+
+        /*
+         * Queues info
+         */
 
         /**
@@ -51 +60 @@
 
         /**
-         * Set if the queues must be durable. The queues won't be lost when rabbitmq
-         * crashes if DURABLE_QUEUES is set trues.
-         */
-        public static String DURABLE_QUEUES = "omq.durable_queue";
-
-        /**
-         * The MESSAGE_TTL_IN_QUEUES controls for how long a message published to
-         * the queues can live before it is discarded. A message that has been in
-         * the queue for longer than the configured TTL is said to be dead.
-         * 
-         * This property must be a non-negative 32 bit integer (0 <= n <= 2^32-1),
-         * describing the TTL period in milliseconds.
-         */
-        public static String MESSAGE_TTL_IN_QUEUES = "omq.message_ttl_queue";
-
-        /**
-         * Set if the system will use ssl
-         */
-        public static String ENABLE_SSL = "omq.enable_ssl";
-
-        /**
-         * Set how many time we have to wait to retry the connection with the server
-         * when this goes down
-         */
-        public static String RETRY_TIME_CONNECTION = "omq.retry_connection";
-
-        /**
-         * Set how many threads will be created to invoke remote methods
-         */
-        public static String NUM_THREADS = "omq.num_threads";
-
-        /**
          * Set the specific name of a multi queue in a specific object
          */
         public static String MULTI_QUEUE_NAME = "omq.multi_queue_name";
+
+        /**
+         * Set if a queue must be durable. The queue won't be lost when RabbitMQ
+         * crashes if DURABLE_QUEUE is set true.
+         */
+        public static String DURABLE_QUEUE = "omq.durable_queue";
 
         /**
@@ -99 +82 @@
 
         /**
+         * Set if a queue must be durable. The queue won't be lost when RabbitMQ
+         * crashes if DURABLE_QUEUE is set true.
+         */
+        public static String DURABLE_MQUEUE = "omq.durable_mqueue";
+
+        /**
+         * Set if server will delete a queue when is no longer in use
+         */
+        public static String AUTO_DELETE_MQUEUE = "omq.auto_mdelete";
+
+        /**
+         * Set if we are declaring an exclusive queue (restricted to this
+         * connection)
+         */
+        public static String EXCLUSIVE_MQUEUE = "omq.exclusive_mqueue";
+
+        /**
+         * The MESSAGE_TTL_IN_QUEUES controls for how long a message published to
+         * the queues can live before it is discarded. A message that has been in
+         * the queue for longer than the configured TTL is said to be dead.
+         * 
+         * This property must be a non-negative 32 bit integer (0 <= n <= 2^32-1),
+         * describing the TTL period in milliseconds.
+         */
+        public static String MESSAGE_TTL_IN_QUEUES = "omq.message_ttl_queue";
+
+        /*
+         * Message info
+         */
+
+        /**
+         * Set the proxy's serializer method
+         */
+        public static String PROXY_SERIALIZER = "omq.serializer";
+
+        /**
+         * Set whether the messages must be compressed or not
+         */
+        public static String ENABLE_COMPRESSION = "omq.compression";
+
+        /**
          * Set 1 to indicate the message will be nonpersistent and 2 to indicate it
          * will be persistent
          */
         public static String DELIVERY_MODE = "omq.delivery_mode";
+
+        /*
+         * ObjectMQ info
+         */
+
+        /**
+         * Set how many threads will be created to invoke remote methods
+         */
+        public static String NUM_THREADS = "omq.num_threads";
 
         /**