source: branches/objectmq_old/src/omq/common/util/ParameterQueue.java

Last change on this file was 35, checked in by stoda, 11 years ago
File size: 2.3 KB
Line 
1package omq.common.util;
2
3/**
4 *
5 * @author Sergi Toda <sergi.toda@estudiants.urv.cat>
6 *
7 */
8public class ParameterQueue {
9
10        /*
11         * Properties environment
12         */
13
14        public static String SERIALIZER_NAME = "omq.serializer";
15
16        /**
17         * Set whether the messages must be compressed or not
18         */
19        public static String ENABLECOMPRESSION = "omq.compression";
20
21        /**
22         * Set the ip where the rabbitmq server is.
23         */
24        public static String SERVER_HOST = "omq.host";
25
26        /**
27         * Set the port that rabbitmq uses.
28         */
29        public static String SERVER_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 the clients event queue. Every client must have a different queue
54         * name.
55         */
56        public static String EVENT_REPLY_QUEUE = "omq.reply_queue_event";
57
58        /**
59         * Set if the queues must be durable. The queues won't be lost when rabbitmq
60         * crashes if DURABLE_QUEUES is set trues.
61         */
62        public static String DURABLE_QUEUES = "omq.durable_queue";
63
64        /**
65         * The MESSAGE_TTL_IN_QUEUES controls for how long a message published to
66         * the queues can live before it is discarded. A message that has been in
67         * the queue for longer than the configured TTL is said to be dead.
68         *
69         * This property must be a non-negative 32 bit integer (0 <= n <= 2^32-1),
70         * describing the TTL period in milliseconds.
71         */
72        public static String MESSAGE_TTL_IN_QUEUES = "omq.message_ttl_queue";
73
74        // TODO persisten messages? the messages will be saved in the disk if this
75        // flag is set true
76
77        public static String ENABLE_SSL = "omq.enable_ssl";
78        public static String DEBUGFILE = "omq.debug_file";
79
80        public static String RETRY_TIME_CONNECTION = "omq.retry_connection";
81
82        /*
83         * Values
84         */
85
86        // Change this!!!
87        public static String RPC_TYPE = "direct";
88
89        public static String NUM_THREADS = "omq.num_threads";
90
91        public static String REGISTRY_NAME = "REGISTRY";
92
93        /**
94         * Time in milis
95         */
96        public static long DEFAULT_TIMEOUT = 1 * 1000 * 60;
97
98}
Note: See TracBrowser for help on using the repository browser.