Changeset 105 for branches/supervisor/src/main/java/omq/server
- Timestamp:
- 10/16/13 16:19:02 (11 years ago)
- Location:
- branches/supervisor/src/main/java/omq/server
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
branches/supervisor/src/main/java/omq/server/InvocationThread.java
r102 r105 35 35 // RemoteObject 36 36 private RemoteObject obj; 37 private String UID;37 private String reference; 38 38 private Properties env; 39 39 private boolean idle; … … 54 54 public InvocationThread(RemoteObject obj) throws Exception { 55 55 this.obj = obj; 56 this. UID= obj.getRef();56 this.reference = obj.getRef(); 57 57 this.env = obj.getEnv(); 58 58 this.broker = obj.getBroker(); … … 176 176 // Get info about which exchange and queue will use 177 177 String exchange = env.getProperty(ParameterQueue.RPC_EXCHANGE, ""); 178 String queue = UID;179 String routingKey = UID;178 String queue = reference; 179 String routingKey = reference; 180 180 181 181 // RemoteObject default queue … … 192 192 channel.queueBind(queue, exchange, routingKey); 193 193 } 194 logger.info("RemoteObject: " + UID+ " declared direct exchange: " + exchange + ", Queue: " + queue + ", Durable: " + durable + ", Exclusive: "194 logger.info("RemoteObject: " + reference + " declared direct exchange: " + exchange + ", Queue: " + queue + ", Durable: " + durable + ", Exclusive: " 195 195 + exclusive + ", AutoDelete: " + autoDelete); 196 196 … … 200 200 201 201 // Get info about the multiQueue 202 String multiExchange = multi + UID;203 // TODO:String multiExchange = multi + exchange + UID;202 String multiExchange = multi + reference; 203 // TODO:String multiExchange = multi + exchange + reference; 204 204 multiQueue = env.getProperty(ParameterQueue.MULTI_QUEUE_NAME); 205 205 … … 217 217 } 218 218 channel.queueBind(multiQueue, multiExchange, ""); 219 logger.info("RemoteObject: " + UID+ " declared fanout exchange: " + multiExchange + ", Queue: " + multiQueue + ", Durable: " + multiDurable219 logger.info("RemoteObject: " + reference + " declared fanout exchange: " + multiExchange + ", Queue: " + multiQueue + ", Durable: " + multiDurable 220 220 + ", Exclusive: " + multiExclusive + ", AutoDelete: " + multiAutoDelete); 221 221 … … 236 236 237 237 public void kill() throws IOException { 238 logger.info("Killing objectmq: " + UID+ " thread id");238 logger.info("Killing objectmq: " + reference + " thread id"); 239 239 killed = true; 240 240 interrupt(); -
branches/supervisor/src/main/java/omq/server/RemoteObject.java
r101 r105 30 30 private static final Logger logger = Logger.getLogger(RemoteObject.class.getName()); 31 31 32 private String UID;32 private String reference; 33 33 private Properties env; 34 34 private transient Broker broker; … … 61 61 public void startRemoteObject(String reference, Broker broker, Properties env) throws Exception { 62 62 this.broker = broker; 63 this. UID= reference;63 this.reference = reference; 64 64 this.env = env; 65 65 … … 87 87 @Override 88 88 public String getRef() { 89 return UID;89 return reference; 90 90 } 91 91
Note: See TracChangeset
for help on using the changeset viewer.