대기열에서 N 개의 메시지를 수동으로 읽거나, onmessage() 메소드에서 Y 시간이 지난 경우 어떻게 할 수 있습니까?

Question

나는 나의 메시지 드리븐 빈에서의 onMessage 방법

읽기 N 메시지를 다음과 같은 논리를 구현하거나 첫 발생 후 트랜잭션을 커밋 중 Y 시간을 기다려야 찾고 있습니다.

이 논리를 구현하는 코드 예제를 얻을 수 있다면 정말 고맙겠습니다. 수 있습니다이 코드 같은

T

Answer 1

뭔가 당신이 원하는합니다. 청취자를 하나의 단일 소비자로 유지하십시오. 동시 적으로로드 균형이 잡히지 않습니다. 그렇지 않으면 까다로워집니다. JEE6을 사용하고 있다면 주석을 통해 jms 리소스를 주입하고 싶을 것입니다. 수신 통화가 없을 경우 Y/N 시간 대기를 차단합니다.

public void onMessage(Message msg) { 

    // So we got a message, let's grab the JMS resources 
    // Note that these could be injected as well, for convenience 

    InitialContext context = new InitialContext(); 
    ConnectionFactory factory = (ConnectionFactory) context.lookup("java:comp/env/jms/connectionFactory"); 
    Destination destination = (Destination) context.lookup("java:comp/env/jms/myQueue"); 
    Connection connection = factory.createConnection(); 
    connection.start(); 
    MessageConsumer consumer = session.createConsumer(destination); 
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); 
    // TODO: handle msg here 

    // So, let's start look for msgs. 
    for (int i=0; i<N; i++) { 
     Message msg_i = consumer.receive(Y/N); 
     // Handle msg_i here. 
    } 
    consumer.close(); 
    session.close(); 
    connection.close(); 
}