如何丢弃队列中的 Tibco EMS 消息（消费者端）

Question

我正在使用队列中的 Tibco JMS (EMS) 消息...我想在每次应用程序运行时清除队列。我可以想到以下逻辑...我认为他们可能是更好的方法

public void clearMessages() throws JMSException{

        Message msg = (Message) queueReceiver.receiveNoWait();
        while(msg != null)
        {
            clearMessages();
        }

        return;
    }

Answer 1

选项 1：您单独确认每条消息；但是，如果您有（许多）数千条消息排队，这种方法可能需要一些时间：

public void clearMessages() throws JMSException{
    Message message = null;
    do {
        message = consumer.receiveNoWait();
     if (message != null) message.acknowledge();
    }
    while (message != null);
}

选项 2：使用 TibjmsAdmin 对象清除 JMS 目标是这样完成的（单击 TIBCO EMS Admin Java API 获取 JavaDoc）：

public void clearMessages(String queueName) throws TibjmsAdminException, TibjmsAdminInvalidNameException{
    TibjmsAdmin jmsAdmin = new TibjmsAdmin("tcp://localhost:7222", "admin", "admin");
    jmsAdmin.purgeQueue(queueName);
    // alternatively purge all queues:
    // jmsAdmin.purgeQueues(">");
}

HTH，

亨德里克