- Timestamp:
- 07/10/13 13:14:30 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/src/main/java/omq/client/listener/ResponseListener.java
r82 r84 120 120 121 121 String reply_queue = env.getProperty(ParameterQueue.RPC_REPLY_QUEUE); 122 boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUES, "false")); 122 boolean durable = Boolean.parseBoolean(env.getProperty(ParameterQueue.DURABLE_QUEUE, "false")); 123 boolean exclusive = Boolean.parseBoolean(env.getProperty(ParameterQueue.EXCLUSIVE_QUEUE, "true")); 124 boolean autoDelete = Boolean.parseBoolean(env.getProperty(ParameterQueue.AUTO_DELETE_QUEUE, "true")); 123 125 124 126 int ttl = Integer.parseInt(env.getProperty(ParameterQueue.MESSAGE_TTL_IN_QUEUES, "-1")); … … 128 130 } 129 131 130 channel.queueDeclare(reply_queue, durable, false, false, args); 131 logger.info("ResponseListener creating queue: " + reply_queue + ", durable: " + durable + "TTL: " + (ttl > 0 ? ttl : "not set")); 132 if (reply_queue == null) { 133 reply_queue = channel.queueDeclare().getQueue(); 134 env.setProperty(ParameterQueue.RPC_REPLY_QUEUE, reply_queue); 135 } else { 136 channel.queueDeclare(reply_queue, durable, exclusive, autoDelete, args); 137 } 138 logger.info("ResponseListener creating queue: " + reply_queue + ", durable: " + durable + ", exclusive: " + exclusive + ", autoDelete: " + autoDelete 139 + ", TTL: " + (ttl > 0 ? ttl : "not set")); 132 140 133 141 // Declare a new consumer
Note: See TracChangeset
for help on using the changeset viewer.