Changeset 77 for trunk/src/main/java/omq/common/util/ParameterQueue.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/common/util/ParameterQueue.java (modified) (3 diffs)

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

@@ -12 +12 @@
          */
 
-        public static String SERIALIZER_NAME = "omq.serializer";
+        /**
+         * 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 ENABLECOMPRESSION = "omq.compression";
+        public static String ENABLE_COMPRESSION = "omq.compression";
 
         /**
          * Set the ip where the rabbitmq server is.
          */
-        public static String SERVER_HOST = "omq.host";
+        public static String RABBIT_HOST = "omq.host";
 
         /**
          * Set the port that rabbitmq uses.
          */
-        public static String SERVER_PORT = "omq.port";
+        public static String RABBIT_PORT = "omq.port";
 
         /**
@@ -51 +54 @@
 
         /**
-         * Set the clients event queue. Every client must have a different queue
-         * name.
-         */
-        public static String EVENT_REPLY_QUEUE = "omq.reply_queue_event";
-
-        /**
          * Set if the queues must be durable. The queues won't be lost when rabbitmq
          * crashes if DURABLE_QUEUES is set trues.
@@ -72 +69 @@
         public static String MESSAGE_TTL_IN_QUEUES = "omq.message_ttl_queue";
 
-        // TODO persisten messages? the messages will be saved in the disk if this
+        // TODO persistent messages? the messages will be saved in the disk if this
         // flag is set true
 
+        /**
+         * Set if the system will use ssl
+         */
         public static String ENABLE_SSL = "omq.enable_ssl";
-        public static String DEBUGFILE = "omq.debug_file";
 
+        /**
+         * 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";
 
-        /*
-         * Values
+        /**
+         * Set how many threads will be created to invoke remote methods
          */
-
-        // Change this!!!
-        public static String RPC_TYPE = "direct";
-
         public static String NUM_THREADS = "omq.num_threads";
 
-        public static String REGISTRY_NAME = "REGISTRY";
+        /**
+         * Set the specific name of a multi queue in a specific object
+         */
+        public static String MULTI_QUEUE_NAME = "omq.multi_queue_name";
+
+        /**
+         * Set if server will delete a queue when is no longer in use
+         */
+        public static String AUTO_DELETE_QUEUE = "omq.auto_delete";
+
+        /**
+         * Set if we are declaring an exclusive queue (restricted to this
+         * connection)
+         */
+        public static String EXCLUSIVE_QUEUE = "omq.exclusive_queue";
+
+        /**
+         * 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";
 
         /**