 |
Return to article
public synchronized Message get(Message m) {
status = Message.STATUS_OK;
Message qm = (Message) queue.get(m.getMessageId());
//apply client requested transformation rule
if (m.getProcessingRule() != "" && qm != null) {
try {
qm = new Message(xslTransformation(qm.toString(), m.getProcessingRule()));
} catch (Exception e) {
System.out.println("QueueManager:get:1:" + e.toString());
}
}
log("QueueManager: retrieved " + m.getMessageId() + " from " + m.getQueueName() + " queue");
return qm;
}
|
Return to article
|  |
|