Как можно программно очистить очередь ActiveMQ с помощью API Apache.NMS?

Question

Мне нужна возможность программной очистки очереди с использованием Apache.NMS (C #).Я просматривал NMS API, но не вижу такой возможности.Это существует?

Answer 1

Нет прямого способа очистки очереди из NMS API, это скорее функция управления. Вы можете преобразовать экземпляр IConnection в Apahce.NMS.ActiveMQ.Connection и затем вызвать DeleteDestination. Это сработало бы, если бы в очереди не было потребителей, но, если они есть, сгенерирует исключение.

Answer 2

Не совсем точно, что вы подразумеваете под «очисткой» очереди (удалить все сообщения?), Но вы можете управлять сообщениями, установив транзакционный сеанс:

ISession consumerSession = = connection.CreateSession(AcknowledgementMode.Transactional);

Тогда вы можете использовать:

//will remove message from queue on success
consumerSession.Commit();

или

//on failure, back on queue
consumerSession.Rollback();