JMS和甲骨文AQ

Question

任何人都可以指向我的一些示例java代碼，告訴我如何監聽Oracle AQ隊列？

感謝 達明

Answer 1

這裏的基礎知識。 conn變量包含一個已經連接到數據庫的常規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(); 

像AQjmsQueueConnectionFactory這樣的Oracle特定類位於包oracle.jms中。