本文整理了Java中org.apache.activemq.command.Message.isRedelivered()
方法的一些代码示例,展示了Message.isRedelivered()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Message.isRedelivered()
方法的具体详情如下:
包路径:org.apache.activemq.command.Message
类名称:Message
方法名:isRedelivered
暂无
代码示例来源:origin: apache/activemq
@Override
public Object evaluate(Message message) {
return Boolean.valueOf(message.isRedelivered());
}
});
代码示例来源:origin: apache/activemq
public void setRedelivered(boolean redelivered) {
if (redelivered) {
if (!isRedelivered()) {
setRedeliveryCounter(1);
}
} else {
if (isRedelivered()) {
setRedeliveryCounter(0);
}
}
}
代码示例来源:origin: apache/activemq
((Destination) message.getRegionDestination()).getDestinationStatistics().getProcessTime().addTime(totalTime);
if (((BaseDestination) message.getRegionDestination()).isPersistJMSRedelivered() && !message.isRedelivered()) {
final int originalValue = message.getRedeliveryCounter();
message.incrementRedeliveryCounter();
代码示例来源:origin: org.apache.activemq/activemq-osgi
@Override
public Object evaluate(Message message) {
return Boolean.valueOf(message.isRedelivered());
}
});
代码示例来源:origin: org.apache.activemq/activemq-all
@Override
public Object evaluate(Message message) {
return Boolean.valueOf(message.isRedelivered());
}
});
代码示例来源:origin: org.apache.activemq/activemq-client
@Override
public Object evaluate(Message message) {
return Boolean.valueOf(message.isRedelivered());
}
});
代码示例来源:origin: pierre/meteo
public Object evaluate(Message message) {
return Boolean.valueOf(message.isRedelivered());
}
});
代码示例来源:origin: org.apache.activemq/activemq-all
public void setRedelivered(boolean redelivered) {
if (redelivered) {
if (!isRedelivered()) {
setRedeliveryCounter(1);
}
} else {
if (isRedelivered()) {
setRedeliveryCounter(0);
}
}
}
代码示例来源:origin: org.apache.activemq/activemq-client
public void setRedelivered(boolean redelivered) {
if (redelivered) {
if (!isRedelivered()) {
setRedeliveryCounter(1);
}
} else {
if (isRedelivered()) {
setRedeliveryCounter(0);
}
}
}
代码示例来源:origin: pierre/meteo
public void setRedelivered(boolean redelivered) {
if (redelivered) {
if (!isRedelivered()) {
setRedeliveryCounter(1);
}
} else {
if (isRedelivered()) {
setRedeliveryCounter(0);
}
}
}
代码示例来源:origin: org.apache.activemq/activemq-osgi
public void setRedelivered(boolean redelivered) {
if (redelivered) {
if (!isRedelivered()) {
setRedeliveryCounter(1);
}
} else {
if (isRedelivered()) {
setRedeliveryCounter(0);
}
}
}
代码示例来源:origin: io.fabric8.ipaas.apps/fabric8mq
protected void populateInitialHeaders(Map<String, Object> map) {
Message message = null;
if (command.isMessage()) {
message = (Message) this.command;
}
if (command.isMessageDispatch()) {
message = ((MessageDispatch) command).getMessage();
}
if (message != null) {
map.put("JMSCorrelationID", message.getCorrelationId());
map.put("JMSDestination", message.getDestination());
map.put("JMSExpiration", message.getExpiration());
map.put("JMSMessageID", message.getMessageId().toString());
map.put("JMSPriority", message.getPriority());
map.put("JMSRedelivered", message.isRedelivered());
map.put("JMSTimestamp", message.getTimestamp());
map.put("JMSReplyTo", message.getReplyTo());
map.put("JMSType", message.getType());
map.put("JMSXGroupID", message.getGroupID());
map.put("JMSXGroupSeq", message.getGroupSequence());
map.put("JMSXUserID", message.getUserID());
}
}
}
代码示例来源:origin: io.fabric8.jube.images.fabric8/fabric8-mq
case AT_LEAST_ONCE:
case EXACTLY_ONCE:
publish.dup(publish.dup() || md.getMessage().isRedelivered());
case AT_MOST_ONCE:
代码示例来源:origin: io.fabric8.ipaas.apps/fabric8mq
case AT_LEAST_ONCE:
case EXACTLY_ONCE:
publish.dup(publish.dup() || md.getMessage().isRedelivered());
case AT_MOST_ONCE:
代码示例来源:origin: org.apache.activemq/activemq-all
case AT_LEAST_ONCE:
case EXACTLY_ONCE:
publish.dup(publish.dup() ? true : md.getMessage().isRedelivered());
case AT_MOST_ONCE:
代码示例来源:origin: org.apache.activemq/activemq-mqtt
case AT_LEAST_ONCE:
case EXACTLY_ONCE:
publish.dup(publish.dup() ? true : md.getMessage().isRedelivered());
case AT_MOST_ONCE:
代码示例来源:origin: org.apache.activemq/activemq-osgi
((Destination) message.getRegionDestination()).getDestinationStatistics().getProcessTime().addTime(totalTime);
if (((BaseDestination) message.getRegionDestination()).isPersistJMSRedelivered() && !message.isRedelivered()) {
final int originalValue = message.getRedeliveryCounter();
message.incrementRedeliveryCounter();
代码示例来源:origin: org.apache.activemq/activemq-osgi
case AT_LEAST_ONCE:
case EXACTLY_ONCE:
publish.dup(publish.dup() ? true : md.getMessage().isRedelivered());
case AT_MOST_ONCE:
代码示例来源:origin: org.apache.activemq/activemq-all
((Destination) message.getRegionDestination()).getDestinationStatistics().getProcessTime().addTime(totalTime);
if (((BaseDestination) message.getRegionDestination()).isPersistJMSRedelivered() && !message.isRedelivered()) {
final int originalValue = message.getRedeliveryCounter();
message.incrementRedeliveryCounter();
代码示例来源:origin: org.apache.activemq/activemq-broker
((Destination) message.getRegionDestination()).getDestinationStatistics().getProcessTime().addTime(totalTime);
if (((BaseDestination) message.getRegionDestination()).isPersistJMSRedelivered() && !message.isRedelivered()) {
final int originalValue = message.getRedeliveryCounter();
message.incrementRedeliveryCounter();
内容来源于网络,如有侵权,请联系作者删除!