谁能给我一些示例java代码,向我展示如何监听Oracle AQ队列?
谢谢达米恩
发布于 2010-12-09 01:58:31
这里有一些基础知识。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.jms包中包含特定于oracle的类,如AQjmsQueueConnectionFactory。
https://stackoverflow.com/questions/4390351
复制相似问题