oracle - JMS 和 Oracle AQ

Question

任何人都可以向我指出一些示例 Java 代码，这些代码向我展示了如何在 Oracle AQ 队列上进行监听？

谢谢达米安

Answer 1

这是基础知识。conn 变量包含一个已经连接到数据库的常规 JDBC Connection 类。

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 包中。