MessageListener가 Oracle Queue의 메시지를 청취하지 않습니다.

Question

Oracle Advanced Queue가 구현되었습니다. & 청취자 프로그램을 작성하고 있습니다.

package com.myprog; 

import java.io.File; 
import java.io.FileInputStream; 
import java.io.StringWriter; 
import java.sql.Connection; 
import java.sql.DriverManager; 
import java.util.Properties; 

import javax.jms.ExceptionListener; 
import javax.jms.JMSException; 
import javax.jms.Message; 
import javax.jms.MessageConsumer; 
import javax.jms.MessageListener; 
import javax.jms.Queue; 
import javax.jms.QueueConnection; 
import javax.jms.QueueConnectionFactory; 
import javax.jms.Session; 
import javax.jms.TextMessage; 

import oracle.jms.AQjmsFactory; 
import oracle.jms.AQjmsSession; 

import org.apache.log4j.Logger; 

public class abc implements MessageListener, ExceptionListener { 
private static String queueUserName = "admin"; 
private static String queueName = "my_queue"; 

// Initialize the logger 
private static Logger log = Logger.getLogger(abc.class); 

public static void main(String[] args) { 
    final String METHOD_NAME = "main()"; 

    abc a = new abc();    

     Queue queue; 
     try { 
     QueueConnection QCon = getConnection(); 
     Session session = QCon.createQueueSession(false, Session.AUTO_ACKNOWLEDGE); 
     QCon.start(); 

     queue = ((AQjmsSession) session).getQueue(queueUserName, queueName); 
     MessageConsumer consumer = session.createConsumer(queue);  

     consumer.setMessageListener(a); 
     QCon.setExceptionListener(a); 

     consumer.close(); 
     session.close(); 
     QCon.close(); 
     } catch (JMSException e) { 
     e.printStackTrace(); 
     }   

} 

public static QueueConnection getConnection() { 
    String hostname = "myhost"; 
    String oracle_sid = "mysid"; 
    int portno = 1521; 
    String userName = "myapp"; 
    String password = "pwd"; 
    String driver = "thin"; 
    QueueConnectionFactory QFac = null; 
    QueueConnection QCon = null; 
    try { 
    // get connection factory , not going through JNDI here 
    QFac = AQjmsFactory.getQueueConnectionFactory(hostname, oracle_sid, portno,driver); 

    // create connection 
    QCon = QFac.createQueueConnection(userName, password); 
    } catch (Exception e) { 
    e.printStackTrace(); 
    } 
    return QCon; 
} 

@Override 
public void onException(JMSException e) { 
    log.error(e);  
} 

@Override 
public void onMessage(Message message) { 
    TextMessage msg = (TextMessage) message; 

    try { 
     String m = msg.getText(); 
     System.out.println("m="+m); 
     log.info("MESSAGE RECEIVED " + m); 
    } catch (JMSException e) { 
     log.error(e); 
    } 
} 

}

이 프로그램은 오라클 큐의 메시지를 듣고 &을 계속 실행하는 독립 실행 형 프로그램입니다 참고 : 다음은 내 샘플입니다. 나는이 클래스 파일 & 실행 그것의 항아리를 만들 때

불행하게도, 그냥 다음 &를 실행 & 대기열에 단 1 메시지를 소비 종료합니다. 청취자가 대기열 수신 대기 중 &을 계속 실행하지 않는 이유는 무엇입니까?

나는 계속 듣고 있다고 생각했다. & 대기열에있는 모든 메시지를 검색한다. & 그런 다음 영원히 듣기 모드로 남아있을 것이지만, 그런 식으로 행동하지는 않는다.

무엇이 잘못되었는지 알 수있는 사람이 있으면 감사하게 생각하십시오.

감사

Answer 1

는 여기에 또 다른 JMS 예제는 여러 개의 메시지를 처리하는 루프 방법의 예입니다.

Performs a JNDI lookup of the ConnectionFactory and Destination. 
Creates a Connection and a Session. 
Creates a MessageConsumer: 

consumer = session.createConsumer(dest); 
Starts the connection, causing message delivery to begin: 

connection.start(); 
Receives the messages sent to the destination until the end-of-message-stream control message is received: 

while (true) { 
    Message m = consumer.receive(1); 
    if (m != null) { 
    if (m instanceof TextMessage) { 
     message = (TextMessage) m; 
     System.out.println("Reading message: " + 
     message.getText()); 
    } else { 
     break; 
    } 
    } 
} 

Because the control message is not a TextMessage, the receiving program terminates the while loop and stops receiving messages after the control message arrives. 
Closes the connection in a finally block, automatically closing the session and MessageConsumer. 

while 루프에서이 코드를 래핑하면 빠져 나갈 수 있습니다. 이것은 JMS가 연결 및 세션 객체를 처리하는 방법과 자동으로 닫는 방법에 따라 다르지만, 이것을 그냥 감쌀 수 있습니다.

while(true) { 
     QCon.start(); 

     queue = ((AQjmsSession) session).getQueue(queueUserName, queueName); 
     MessageConsumer consumer = session.createConsumer(queue);  

     consumer.setMessageListener(a); 
     QCon.setExceptionListener(a); 

     consumer.close(); 
} 

Answer 2

시작 후 바로 연결/세션을 종료하기 때문에 모든 것이 있습니다. JVM에서 영원히 실행되는 데몬 스레드를 시작하는 프로세스가 필요합니다. JMS는 JVM 실행을 유지할 책임이 없습니다. 이를 달성하기 위해 잠 들어있는 스레드를 만들어야합니다.