PrefetchPolicy가있는 ActiveMQ-cpp 브로커 URI가 적용되지 않음

Question

VSM 2010과 함께 activemq-cpp 3.7.0을 사용하여 클라이언트를 빌드하면 서버는 ActiveMQ 5.8입니다. here과 같은 CMS 구성을 기반으로 다음과 비슷한 코드를 사용하여 메시지 소비자를 만들었습니다. ConnClass은 ExceptionListener 및 MessageListener입니다. cms::Session::commit()에 전화하기 전에 단 하나의 메시지 만 사용하려고합니다.

void ConnClass::setup() 
{ 

    // Create a ConnectionFactory 
    std::tr1::shared_ptr<ConnectionFactory> connectionFactory(
     ConnectionFactory::createCMSConnectionFactory(
      "tcp://localhost:61616?cms.PrefetchPolicy.queuePrefetch=1"); 

    // Create a Connection 
    m_connection = std::tr1::shared_ptr<cms::Connection>(
     connectionFactory->createConnection()); 

    m_connection->start(); 
    m_connection->setExceptionListener(this); 

    // Create a Session 
    m_session = std::tr1::shared_ptr<cms::Session>(
     m_connection->createSession(Session::SESSION_TRANSACTED)); 


    // Create the destination (Queue) 
    m_destination = std::tr1::shared_ptr<cms::Destination>(
     m_session->createQueue("myqueue?consumer.prefetchSize=1")); 

    // Create a MessageConsumer from the Session to the Queue 
    m_consumer = std::tr1::shared_ptr<cms::MessageConsumer>(
     m_session->createConsumer(m_destination.get())); 

    m_consumer->setMessageListener(this); 

} 

void ConnClass::onMessage(const Message* message) 
{ 
    // read message code ... 
    // schedule a processing event for 
    // another thread that calls m_session->commit() when done 
} 

문제는 내가 m_session->commit()를 호출하기 전에 대신에 하나의 메시지의 여러 메시지를 수신하고합니다 - commit() 호출이 사용자 입력에 의해 트리거 때문에 나는 이것을 알고있다. commit()을 호출하기 전에 onMessage()을 한 번만 호출하려면 어떻게해야합니까?

Answer 1

그런 식으로 작동하지 않습니다. 비동기 소비자를 사용할 때 메시지는 onMessage 메서드가 완료 될 때 최대한 빠르게 전달됩니다. 하나의 메시지 만 사용하려면 동기화 수신 통화를 사용하십시오.

비동기 사용자의 경우 프리 페치를 사용하면 브로커가 한 번에 하나씩 실행하는 대신 클라이언트에서 작업을 버퍼링 할 수 있으므로 일반적으로 비동기식 onMessage 호출이 완료되면 ack가 다음으로 전송되므로 더 나은 결과를 얻을 수 있습니다. 브로커가 다음 메시지를 클라이언트에 보냅니다.

Answer 2

예,이 사실도 발견되었습니다. 그러나 대상 URI 옵션 ("consumer.prefetchSize = 15", http://activemq.apache.org/cms/configuring.html#Configuring-DestinationURIParameters)을 비동기 소비자 용으로 사용하면 올바르게 작동합니다.

BTW, 난 그냥 CentOS는 최신 팀에 의해 ActiveMQ를-CPP의 v3.9.4과의 ActiveMQ의 v5.12.1 7

감사를 사용!