ActiveMQ - удаление очередей программно

Question

Товарищ StackOverflowers, есть ли способ для меня, чтобы удалить очередь или тему в ActiveMQ программно? Я использую стандартную постоянство ActiveMQ, и мое приложение требует, чтобы при запуске все новые очереди создавались динамически (если в очереди не хранятся сообщения, и в этом случае очередь должна оставаться существующей).

Я также создаю все очереди программно через сеансы. Есть ли эквивалент этой процедуры, только для удаления очереди? Запросы и итерации по существующим очередям также были бы полезны, но я пока не нашел способа сделать это.

Answer 1

Вы также можете Удалить пункты назначения , которые неактивны в течение некоторого периода времени.Доступно с Active MQ 5.4

В качестве альтернативы, если вы используете встроенный ActiveMQ, вы можете использовать API для удаления адресатов: Region.removeDestination

Answer 2

Чтобы удалить пункт назначения из ActiveMQ программным способом, вам потребуется сделать это через JMX, используя методы removeTopic и removeQueue в посреднике MBean (org.apache.activemq:BrokerName=localhost,Type=Broker). Я опубликовал пример кода, чтобы продемонстрировать это, включая использование метода removeTopic в Gist:

http://gist.github.com/439668

Надеюсь, это поможет.

Брюс

Answer 3

Если вы используете пружинный JmsTemplate, вы можете сделать это следующим образом:

Connection cn = getJmsTemplate().getConnectionFactory().createConnection();
ActiveMQDestination destination = ActiveMQDestination.createDestination(queueName, ActiveMQDestination.QUEUE_TYPE);             

if(cn instanceof PooledConnection){
    ((PooledConnection)cn).getConnection().destroyDestination(destination );
}

Answer 4

Хотя конкретных примеров не так много, здесь есть некоторая документация: http://activemq.apache.org/how-do-i-purge-a-queue.html