Changeset 54 for trunk/src/main/java/omq/client/listener
- Timestamp:
- 06/21/13 12:42:25 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/src/main/java/omq/client/listener/ResponseListener.java
r53 r54 55 55 @Override 56 56 public void run() { 57 logger.info("ResponseListener started"); 57 58 Delivery delivery; 58 59 String uid_request; … … 122 123 123 124 channel.queueDeclare(reply_queue, durable, false, false, args); 125 logger.info("ResponseListener creating queue: " + reply_queue + ", durable: " + durable); 124 126 125 127 // Declare a new consumer
Note: See TracChangeset
for help on using the changeset viewer.