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

Message.isAdvisory介绍

暂无

代码示例

代码示例来源：origin: apache/activemq

@Override
public boolean isAdvisory() {
  return message.isAdvisory();
}

代码示例来源：origin: apache/activemq

@Override
public void send(ProducerBrokerExchange context, Message message) throws Exception {
  if (!message.isAdvisory() && !(local && message.getBrokerPath() != null)) {
    ActiveMQDestination queueConsumers = getQueueConsumersWildcard(message.getDestination());
    send(context, message, queueConsumers);
  }
  super.send(context, message);
}

代码示例来源：origin: apache/activemq

if (message.isAdvisory()) {
  if (consumerInfo != null && consumerInfo.isNetworkSubscription() && isAdvisoryInterpretedByNetworkBridge(message)) {

代码示例来源：origin: org.apache.activemq/activemq-broker

@Override
public boolean isAdvisory() {
  return message.isAdvisory();
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

@Override
public boolean isAdvisory() {
  return message.isAdvisory();
}

代码示例来源：origin: pierre/meteo

public boolean isAdvisory() {
    return message.isAdvisory();
  }
}

代码示例来源：origin: org.apache.activemq/activemq-all

@Override
public boolean isAdvisory() {
  return message.isAdvisory();
}

代码示例来源：origin: pierre/meteo

public void send(ProducerBrokerExchange context, Message message) throws Exception {
  if (!message.isAdvisory()) {
    ActiveMQDestination queueConsumers = getQueueConsumersWildcard(message.getDestination());
    send(context, message, queueConsumers);
  }
  super.send(context, message);
}

代码示例来源：origin: org.apache.activemq/activemq-broker

@Override
public void send(ProducerBrokerExchange context, Message message) throws Exception {
  if (!message.isAdvisory() && !(local && message.getBrokerPath() != null)) {
    ActiveMQDestination queueConsumers = getQueueConsumersWildcard(message.getDestination());
    send(context, message, queueConsumers);
  }
  super.send(context, message);
}

代码示例来源：origin: org.apache.activemq/activemq-all

@Override
public void send(ProducerBrokerExchange context, Message message) throws Exception {
  if (!message.isAdvisory() && !(local && message.getBrokerPath() != null)) {
    ActiveMQDestination queueConsumers = getQueueConsumersWildcard(message.getDestination());
    send(context, message, queueConsumers);
  }
  super.send(context, message);
}

代码示例来源：origin: org.apache.activemq/activemq-osgi

@Override
public void send(ProducerBrokerExchange context, Message message) throws Exception {
  if (!message.isAdvisory() && !(local && message.getBrokerPath() != null)) {
    ActiveMQDestination queueConsumers = getQueueConsumersWildcard(message.getDestination());
    send(context, message, queueConsumers);
  }
  super.send(context, message);
}

代码示例来源：origin: pierre/meteo

protected boolean matchesForwardingFilter(Message message) {
  if (contains(message.getBrokerPath(), networkBrokerId)) {
    if (LOG.isTraceEnabled()) {
      LOG.trace("Message all ready routed once through this broker ("
          + networkBrokerId + "), path: "
          + Arrays.toString(message.getBrokerPath()) + " - ignoring: " + message);
    }
    return false;
  }
  int hops = message.getBrokerPath() == null ? 0 : message.getBrokerPath().length;
  if (hops >= networkTTL) {
    if (LOG.isTraceEnabled()) {
      LOG.trace("Message restricted to " + networkTTL + " network hops ignoring: " + message);
    }
    return false;
  }
  // Don't propagate advisory messages about network subscriptions
  if (message.isAdvisory() && message.getDataStructure() != null && message.getDataStructure().getDataStructureType() == CommandTypes.CONSUMER_INFO) {
    ConsumerInfo info = (ConsumerInfo)message.getDataStructure();
    hops = info.getBrokerPath() == null ? 0 : info.getBrokerPath().length;
    if (hops >= networkTTL) {
      if (LOG.isTraceEnabled()) {
        LOG.trace("ConsumerInfo advisory restricted to " + networkTTL + " network hops ignoring: " + message);
      }
      return false;
    }
  }
  return true;
}

代码示例来源：origin: org.apache.activemq/activemq-client

if (message.isAdvisory()) {
  if (consumerInfo != null && consumerInfo.isNetworkSubscription() && isAdvisoryInterpretedByNetworkBridge(message)) {

代码示例来源：origin: org.apache.activemq/activemq-all

if (message.isAdvisory()) {
  if (consumerInfo != null && consumerInfo.isNetworkSubscription() && isAdvisoryInterpretedByNetworkBridge(message)) {

代码示例来源：origin: org.apache.activemq/activemq-osgi

if (message.isAdvisory()) {
  if (consumerInfo != null && consumerInfo.isNetworkSubscription() && isAdvisoryInterpretedByNetworkBridge(message)) {