使用activemq-cpp启动应用程序后，立即清除activemq队列中的现有消息

Question

我有一个应用程序，它在activemq中充当队列的使用者。此应用程序是在c++上编写的，并使用activemq-cpp来获取activemq的服务。

我想要实现的是，当我的应用程序关闭并再次启动时，它应该首先删除在应用程序关闭期间填充到队列中的所有消息，即它应该首先删除队列中的所有旧消息，然后开始接收新消息。

有没有办法使用activemq-cpp来实现这一点？

Answer 1

如果您将连接实例强制转换为ActiveMQConnection，则有一个destroyDestination方法将从代理中删除目的地，如果调用时没有活动的订阅，则会删除所有消息，否则它将抛出异常，因此要为此做好准备。下面是一小段代码。

    ActiveMQConnection* connection =
        dynamic_cast<ActiveMQConnection*>( cmsConnection );

    try {
        connection->destroyDestination(destination);
    } catch(Exception& ex) {
    }