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

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