JMS и Oracle 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(); 

Специфические классы Oracle, такие как aqjmsqueueConnectionFactory, находятся в пакете Oracle.jms.