本文整理了Java中org.objectweb.joram.mom.dest.Queue.checkDelivery
方法的一些代码示例,展示了Queue.checkDelivery
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Queue.checkDelivery
方法的具体详情如下:
包路径:org.objectweb.joram.mom.dest.Queue
类名称:Queue
方法名:checkDelivery
[英]Returns true if conditions are ok to deliver the message. This method must be overloaded in subclasses. Be careful only the message header is accessible.
[中]如果条件适合传递消息,则返回true。此方法必须在子类中重载。小心,只有消息头是可访问的。
代码示例来源:origin: org.objectweb.joram/joram-mom-core
checkDelivery(message.getHeaderMessage())) {
message.incDeliveryCount();
nbMsgsDeliverSinceCreation++;
代码示例来源:origin: org.ow2.joram/joram-mom-core
checkDelivery(message.getHeaderMessage())) {
message.incDeliveryCount();
nbMsgsDeliverSinceCreation++;
代码示例来源:origin: org.ow2.joram/joram-mom-core
/**
* get mom message, delete if remove = true.
*
* @param msgId message identification
* @param remove if true delete message
* @return mom message
*/
protected Message getQueueMessage(String msgId, boolean remove) {
if (logger.isLoggable(BasicLevel.DEBUG))
logger.log(BasicLevel.DEBUG, "Queue.getMessage(" + msgId + ',' + remove + ')');
Message message = getMomMessage(msgId);
if (checkDelivery(message.getHeaderMessage())) {
message.incDeliveryCount();
nbMsgsDeliverSinceCreation++;
// use in sub class see ClusterQueue
messageDelivered(message.getId());
if (logger.isLoggable(BasicLevel.DEBUG))
logger.log(BasicLevel.DEBUG, "Message " + msgId);
if (remove) {
messages.remove(message);
message.delete();
}
}
return message;
}
代码示例来源:origin: org.objectweb.joram/joram-mom-core
/**
* get mom message, delete if remove = true.
*
* @param msgId message identification
* @param remove if true delete message
* @return mom message
*/
protected Message getQueueMessage(String msgId, boolean remove) {
if (logger.isLoggable(BasicLevel.DEBUG))
logger.log(BasicLevel.DEBUG, "Queue.getMessage(" + msgId + ',' + remove + ')');
Message message = getMomMessage(msgId);
if (checkDelivery(message.getHeaderMessage())) {
message.incDeliveryCount();
nbMsgsDeliverSinceCreation++;
// use in sub class see ClusterQueue
messageDelivered(message.getIdentifier());
if (logger.isLoggable(BasicLevel.DEBUG))
logger.log(BasicLevel.DEBUG, "Message " + msgId);
if (remove) {
messages.remove(message);
message.delete();
}
}
return message;
}
内容来源于网络,如有侵权,请联系作者删除!