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

Queue.isPrioritizedMessages介绍

暂无

代码示例

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

/**
 * Construct
 * @param broker
 * @param queue
 */
public StoreQueueCursor(Broker broker,Queue queue) {
  super((queue != null ? queue.isPrioritizedMessages():false));
  this.broker=broker;
  this.queue = queue;
  this.persistent = new QueueStorePrefetch(queue, broker);
  currentCursor = persistent;
}

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

/**
   * @param broker 
   * @param queue
   * @return the cursor
   */
  public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
    return new VMPendingMessageCursor(queue.isPrioritizedMessages());
  }
}

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

/**
 * @param broker 
 * @param queue
 * @return the cursor
 * @see org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy#getQueuePendingMessageCursor(org.apache.openjpa.lib.util.concurrent.Queue,
 *      org.apache.activemq.kaha.Store)
 */
public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
  return new FilePendingMessageCursor(broker,"PendingCursor:" + queue.getName(),queue.isPrioritizedMessages());
}

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

PendingList messagesInMemory = isPrioritizedMessages() ?
    new PrioritizedPendingList() : new OrderedPendingList();
pagedInMessagesLock.readLock().lock();

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

if (isPrioritizedMessages() && !dispatchPendingList.isEmpty() && list != null && !list.isEmpty()) {

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

if (isPrioritizedMessages()) {
  resultList = new PrioritizedPendingList();
} else {

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

this.messages = new VMPendingMessageCursor(isPrioritizedMessages());
} else {
  this.messages = new StoreQueueCursor(broker, this);

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

/**
 * Construct
 * @param broker
 * @param queue
 */
public StoreQueueCursor(Broker broker,Queue queue) {
  super((queue != null ? queue.isPrioritizedMessages():false));
  this.broker=broker;
  this.queue = queue;
  this.persistent = new QueueStorePrefetch(queue, broker);
  currentCursor = persistent;
}

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

/**
   * @param broker 
   * @param queue
   * @return the cursor
   */
  public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
    return new VMPendingMessageCursor(queue.isPrioritizedMessages());
  }
}

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

/**
 * Construct
 * @param broker
 * @param queue
 */
public StoreQueueCursor(Broker broker,Queue queue) {
  super((queue != null ? queue.isPrioritizedMessages():false));
  this.broker=broker;
  this.queue = queue;
  this.persistent = new QueueStorePrefetch(queue, broker);
  currentCursor = persistent;
}

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

/**
 * Construct
 * @param broker
 * @param queue
 */
public StoreQueueCursor(Broker broker,Queue queue) {
  super((queue != null ? queue.isPrioritizedMessages():false));
  this.broker=broker;
  this.queue = queue;
  this.persistent = new QueueStorePrefetch(queue, broker);
  currentCursor = persistent;
}

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

/**
   * @param broker 
   * @param queue
   * @return the cursor
   */
  public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
    return new VMPendingMessageCursor(queue.isPrioritizedMessages());
  }
}

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

/**
   * @param broker 
   * @param queue
   * @return the cursor
   */
  public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
    return new VMPendingMessageCursor(queue.isPrioritizedMessages());
  }
}

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

/**
   * @param broker 
   * @param queue
   * @return the cursor
   */
  public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
    return new VMPendingMessageCursor(queue.isPrioritizedMessages());
  }
}

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

/**
 * Construct
 * @param broker 
 * @param queue
 */
public StoreQueueCursor(Broker broker,Queue queue) {
  super((queue != null ? queue.isPrioritizedMessages():false));
  this.broker=broker;
  this.queue = queue;
  this.persistent = new QueueStorePrefetch(queue);
  currentCursor = persistent;
}

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

/**
 * @param broker 
 * @param queue
 * @return the cursor
 * @see org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy#getQueuePendingMessageCursor(org.apache.openjpa.lib.util.concurrent.Queue,
 *      org.apache.activemq.kaha.Store)
 */
public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
  return new FilePendingMessageCursor(broker,"PendingCursor:" + queue.getName(),queue.isPrioritizedMessages());
}

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

/**
 * @param broker 
 * @param queue
 * @return the cursor
 * @see org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy#getQueuePendingMessageCursor(org.apache.openjpa.lib.util.concurrent.Queue,
 *      org.apache.activemq.kaha.Store)
 */
public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
  return new FilePendingMessageCursor(broker,"PendingCursor:" + queue.getName(),queue.isPrioritizedMessages());
}

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

/**
 * @param broker 
 * @param queue
 * @return the cursor
 * @see org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy#getQueuePendingMessageCursor(org.apache.openjpa.lib.util.concurrent.Queue,
 *      org.apache.activemq.kaha.Store)
 */
public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
  return new FilePendingMessageCursor(broker,"PendingCursor:" + queue.getName(),queue.isPrioritizedMessages());
}

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

/**
 * @param broker 
 * @param queue
 * @return the cursor
 * @see org.apache.activemq.broker.region.policy.PendingQueueMessageStoragePolicy#getQueuePendingMessageCursor(org.apache.openjpa.lib.util.concurrent.Queue,
 *      org.apache.activemq.kaha.Store)
 */
public PendingMessageCursor getQueuePendingMessageCursor(Broker broker,Queue queue) {
  return new FilePendingMessageCursor(broker,"PendingCursor:" + queue.getName(),queue.isPrioritizedMessages());
}

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

if (isPrioritizedMessages() && !dispatchPendingList.isEmpty() && list != null && !list.isEmpty()) {