JMS和Oracle AQ

Question

有人可以将我指向一些示例Java代码，向我展示如何在Oracle AQ队列上聆听？

谢谢达米安

Answer 1

这是基础。 CONN变量包含已连接到DB的常规JDBC连接类。

QueueConnection queueConnection = AQjmsQueueConnectionFactory. 
        createQueueConnection(conn); 
QueueSession queueSession = queueConnection. 
        createQueueSession(true, Session.SESSION_TRANSACTED); 
Queue queue=queueSession.createQueue("my_oracle_queue"); 
QueueReceiver receiver= queueSession.createReceiver(queue); 
queueConnection.start(); 
Message message=receiver.receive(); 

Oracle特定的类（例如AQJMSqueUeconnectionFactory）在软件包oracle.jms中。