org.objectweb.joram.mom.dest.Queue.postProcess()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(1.4k)|赞(0)|评价(0)|浏览(60)

本文整理了Java中org.objectweb.joram.mom.dest.Queue.postProcess方法的一些代码示例,展示了Queue.postProcess的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Queue.postProcess方法的具体详情如下:
包路径:org.objectweb.joram.mom.dest.Queue
类名称:Queue
方法名:postProcess

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);

相关文章