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

Queue.addAll介绍

暂无

代码示例

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

protected void doBrowseList(List<Message> browseList, int max, PendingList list, ReentrantReadWriteLock lock, ConnectionContext connectionContext, String name) throws Exception {
  List<MessageReference> toExpire = new ArrayList<MessageReference>();
  lock.readLock().lock();
  try {
    addAll(list.values(), browseList, max, toExpire);
  } finally {
    lock.readLock().unlock();
  }
  for (MessageReference ref : toExpire) {
    if (broker.isExpired(ref)) {
      LOG.debug("expiring from {}: {}", name, ref);
      messageExpired(connectionContext, ref);
    } else {
      lock.writeLock().lock();
      try {
        list.remove(ref);
      } finally {
        lock.writeLock().unlock();
      }
      ref.decrementReferenceCount();
    }
  }
}

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

protected void doBrowseList(List<Message> browseList, int max, PendingList list, ReentrantReadWriteLock lock, ConnectionContext connectionContext, String name) throws Exception {
  List<MessageReference> toExpire = new ArrayList<MessageReference>();
  lock.readLock().lock();
  try {
    addAll(list.values(), browseList, max, toExpire);
  } finally {
    lock.readLock().unlock();
  }
  for (MessageReference ref : toExpire) {
    if (broker.isExpired(ref)) {
      LOG.debug("expiring from {}: {}", name, ref);
      messageExpired(connectionContext, ref);
    } else {
      lock.writeLock().lock();
      try {
        list.remove(ref);
      } finally {
        lock.writeLock().unlock();
      }
      ref.decrementReferenceCount();
    }
  }
}

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

protected void doBrowseList(List<Message> browseList, int max, PendingList list, ReentrantReadWriteLock lock, ConnectionContext connectionContext, String name) throws Exception {
  List<MessageReference> toExpire = new ArrayList<MessageReference>();
  lock.readLock().lock();
  try {
    addAll(list.values(), browseList, max, toExpire);
  } finally {
    lock.readLock().unlock();
  }
  for (MessageReference ref : toExpire) {
    if (broker.isExpired(ref)) {
      LOG.debug("expiring from {}: {}", name, ref);
      messageExpired(connectionContext, ref);
    } else {
      lock.writeLock().lock();
      try {
        list.remove(ref);
      } finally {
        lock.writeLock().unlock();
      }
      ref.decrementReferenceCount();
    }
  }
}

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

protected void doBrowseList(List<Message> browseList, int max, PendingList list, ReentrantReadWriteLock lock, ConnectionContext connectionContext, String name) throws Exception {
  List<MessageReference> toExpire = new ArrayList<MessageReference>();
  lock.readLock().lock();
  try {
    addAll(list.values(), browseList, max, toExpire);
  } finally {
    lock.readLock().unlock();
  }
  for (MessageReference ref : toExpire) {
    if (broker.isExpired(ref)) {
      LOG.debug("expiring from {}: {}", name, ref);
      messageExpired(connectionContext, ref);
    } else {
      lock.writeLock().lock();
      try {
        list.remove(ref);
      } finally {
        lock.writeLock().unlock();
      }
      ref.decrementReferenceCount();
    }
  }
}

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

addAll(pagedInPendingDispatch, browseList, max, toExpire);
  for (MessageReference ref : toExpire) {
    pagedInPendingDispatch.remove(ref);
pagedInMessagesLock.readLock().lock();
try {
  addAll(pagedInMessages.values(), browseList, max, toExpire);
} finally {
  pagedInMessagesLock.readLock().unlock();