source: trunk/src/main/java/omq/common/util/ParameterQueue.java @ 83

Last change on this file since 83 was 83, checked in by stoda, 11 years ago

J

File size: 2.8 KB
Line 
1package omq.common.util;
2
3/**
4 * This class is used to create new environments.
5 *
6 * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
7 *
8 */
9public class ParameterQueue {
10
11        /**
12         * Set the proxy's serializer method
13         */
14        public static String PROXY_SERIALIZER = "omq.serializer";
15
16        /**
17         * Set whether the messages must be compressed or not
18         */
19        public static String ENABLE_COMPRESSION = "omq.compression";
20
21        /**
22         * Set the ip where the rabbitmq server is.
23         */
24        public static String RABBIT_HOST = "omq.host";
25
26        /**
27         * Set the port that rabbitmq uses.
28         */
29        public static String RABBIT_PORT = "omq.port";
30
31        /**
32         * Set the clients username
33         */
34        public static String USER_NAME = "omq.username";
35
36        /**
37         * Set the clients password
38         */
39        public static String USER_PASS = "omq.pass";
40
41        /**
42         * Set the exchange where the objectmq are listening
43         */
44        public static String RPC_EXCHANGE = "omq.rpc_exchange";
45
46        /**
47         * Set the clients reply queue. Every client must have a different queue
48         * name.
49         */
50        public static String RPC_REPLY_QUEUE = "omq.reply_queue_rpc";
51
52        /**
53         * Set if the queues must be durable. The queues won't be lost when rabbitmq
54         * crashes if DURABLE_QUEUES is set trues.
55         */
56        public static String DURABLE_QUEUES = "omq.durable_queue";
57
58        /**
59         * The MESSAGE_TTL_IN_QUEUES controls for how long a message published to
60         * the queues can live before it is discarded. A message that has been in
61         * the queue for longer than the configured TTL is said to be dead.
62         *
63         * This property must be a non-negative 32 bit integer (0 <= n <= 2^32-1),
64         * describing the TTL period in milliseconds.
65         */
66        public static String MESSAGE_TTL_IN_QUEUES = "omq.message_ttl_queue";
67
68        /**
69         * Set if the system will use ssl
70         */
71        public static String ENABLE_SSL = "omq.enable_ssl";
72
73        /**
74         * Set how many time we have to wait to retry the connection with the server
75         * when this goes down
76         */
77        public static String RETRY_TIME_CONNECTION = "omq.retry_connection";
78
79        /**
80         * Set how many threads will be created to invoke remote methods
81         */
82        public static String NUM_THREADS = "omq.num_threads";
83
84        /**
85         * Set the specific name of a multi queue in a specific object
86         */
87        public static String MULTI_QUEUE_NAME = "omq.multi_queue_name";
88
89        /**
90         * Set if server will delete a queue when is no longer in use
91         */
92        public static String AUTO_DELETE_QUEUE = "omq.auto_delete";
93
94        /**
95         * Set if we are declaring an exclusive queue (restricted to this
96         * connection)
97         */
98        public static String EXCLUSIVE_QUEUE = "omq.exclusive_queue";
99
100        /**
101         * Set 1 to indicate the message will be nonpersistent and 2 to indicate it
102         * will be persistent
103         */
104        public static String DELIVERY_MODE = "omq.delivery_mode";
105
106        /**
107         * Time in milis by default is set in a minute
108         */
109        public static long DEFAULT_TIMEOUT = 1 * 1000 * 60;
110
111}
Note: See TracBrowser for help on using the repository browser.