本文整理了Java中org.objectweb.joram.mom.dest.Queue.postProcess
方法的一些代码示例,展示了Queue.postProcess
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Queue.postProcess
方法的具体详情如下:
包路径:org.objectweb.joram.mom.dest.Queue
类名称:Queue
方法名:postProcess
暂无
代码示例来源:origin: org.ow2.joram/joram-mom-core
if (logger.isLoggable(BasicLevel.DEBUG))
logger.log(BasicLevel.DEBUG, "DistributionQueue.postProcess(...)");
super.postProcess(cm);
代码示例来源:origin: org.objectweb.joram/joram-mom-core
postProcess(clientMsgs);
代码示例来源:origin: org.ow2.joram/joram-mom-core
void processDeliveryTime(AgentId from, QueueDeliveryTimeNot not) throws AccessException {
if (logger.isLoggable(BasicLevel.DEBUG))
logger.log(BasicLevel.DEBUG, "Queue.processDeliveryTime(" + from + ", " + not + ')');
if (not.msg != null) {
if (logmsg.isLoggable(BasicLevel.INFO))
logmsg.log(BasicLevel.INFO, getName() + ": adds new delayed message " + not.msg.getId() + ", " + not.msg.order);
// Adds a message in the list of messages to deliver.
addMessage(not.msg, not.throwsExceptionOnFullDest);
delayedMessageCount -= 1;
//msg.order = arrivalState.getAndIncrementArrivalCount(msg.isPersistent());
}
// Launching a delivery sequence:
deliverMessages(0);
if (not.msg != null) {
ClientMessages clientMsgs = new ClientMessages();
clientMsgs.addMessage(not.msg.getMsg());
postProcess(clientMsgs);
}
}
代码示例来源:origin: org.ow2.joram/joram-mom-core
postProcess(clientMsgs);
内容来源于网络,如有侵权,请联系作者删除!