ActiveMQ-CPP - сообщение redelivery delay не применяется

Question

Я использую ActiveMQ-CPP 3.4.5 для подключения от C++ к брокеру сообщений. Проблема, с которой я столкнулся, связана с политикой переопределения. Сообщения, которые возвращаются в очередь, немедленно возвращаются. Я не ожидаю такого поведения . Я ожидаю, что сообщения будут возвращены после определенного периода времени времени, которое задано политикой пересылки.

Это код отрезала показывает путь настроить Redelivery политику:

policy = new activemq::core::policies::DefaultRedeliveryPolicy(); 

policy->setInitialRedeliveryDelay(0); 
policy->setRedeliveryDelay(10000); 
policy->setMaximumRedeliveries((int)activemq::core::RedeliveryPolicy::NO_MAXIMUM_REDELIVERIES); 

connectionFactory.setRedeliveryPolicy(policy); 

Как я уже сказал, прежде чем я, за исключением сообщений, которые будут повторно доставлены через 10000 мс, но не являются. Они немедленно возвращаются к потребителю.

Кто-нибудь знает, что может быть причиной такого поведения?

Answer 1

Вы устанавливаете начальную задержку на ноль, чтобы они были повторно отправлены сразу же при первом откате транзакции. Если вы хотите, чтобы их задерживали в первом цикле повторной доставки, вам также нужно установить начальную задержку на 10000.

Answer 2

Когда я смотрел на источники ActiveMQ-CPP я нашел следующий фрагмент кода в файле ActiveMQConsumer.cpp:

if(internal->redeliveryDelay > 0 && !this->internal->unconsumedMessages->isClosed()) { 
// TODO - Can't do this until we can control object lifetime. 
// Start up the delivery again a little later. 
// this->internal->scheduler->executeAfterDelay(
// new StartConsumerTask(this), internal->redeliveryDelay); 
    start(); 
} else { 
    start(); 
} 

Так что, кажется, что redeliveryDelay не принимается во внимание после отката на всех. Вот почему, я полагаю, мои сообщения приходят сразу после откат.

метод OnMessage:

void BaseProdListener::onMessage(const cms::Message* message){  
log4cxx::Logger::getLogger("BaseProdListener")->info("onMessage"); 

_message = message; 

try { 
    const cms::TextMessage* textMessage = dynamic_cast< const cms::TextMessage* >(message); 
    std::string text = ""; 
    if(textMessage != NULL) { 
     text = textMessage->getText(); 
     log4cxx::Logger::getLogger("BaseProdListener")->debug("Received message:" + text); 
     handleMessage(text); 
    } 
} catch (cms::CMSException& e){ 
    log4cxx::Logger::getLogger("BaseProdListener")->error(e.getStackTraceString()); 
} 

}