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

Queue.purge介绍

暂无

代码示例

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

public synchronized void purge() throws Exception {
  final long originalMessageCount = destination.getDestinationStatistics().getMessages().getCount();
  ((Queue)destination).purge();
  LOG.info("{} purge of {} messages", destination.getActiveMQDestination().getQualifiedName(), originalMessageCount);
}

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

((Queue) dest).purge();

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

public void purge() throws Exception {
  ((Queue)destination).purge();
}

代码示例来源：origin: jboss-fuse/fabric8

public void purgeQueue(ActiveMQDestination destination) throws Exception {
  Set destinations = getManagedBroker().getQueueRegion().getDestinations(destination);
  for (Iterator i = destinations.iterator(); i.hasNext();) {
    Destination dest = (Destination) i.next();
    if (dest instanceof Queue) {
      Queue regionQueue = (Queue) dest;
      regionQueue.purge();
    }
  }
}

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

public synchronized void purge() throws Exception {
  final long originalMessageCount = destination.getDestinationStatistics().getMessages().getCount();
  ((Queue)destination).purge();
  LOG.info("{} purge of {} messages", destination.getActiveMQDestination().getQualifiedName(), originalMessageCount);
}

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

public synchronized void purge() throws Exception {
  final long originalMessageCount = destination.getDestinationStatistics().getMessages().getCount();
  ((Queue)destination).purge();
  LOG.info("{} purge of {} messages", destination.getActiveMQDestination().getQualifiedName(), originalMessageCount);
}

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

public synchronized void purge() throws Exception {
  final long originalMessageCount = destination.getDestinationStatistics().getMessages().getCount();
  ((Queue)destination).purge();
  LOG.info("{} purge of {} messages", destination.getActiveMQDestination().getQualifiedName(), originalMessageCount);
}