JMS et Oracle AQ

Question

Quelqu'un pourrait-il me pointer vers un exemple de code java qui me montre comment écouter sur une file d'attente Oracle AQ?

Merci Damien

Answer 1

Voici les bases. La variable conn contient une classe de connexion JDBC standard déjà connectée à la base de données.

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(); 

Les classes spécifiques d'oracle comme AQjmsQueueConnectionFactory sont dans le paquet oracle.jms.