JMS e Oracle AQ

Question

Qualcuno dovrebbe essere in grado di puntare a me un po 'di codice Java di esempio che mostra come me per l'ascolto su un AQ coda di Oracle?

Grazie Damien

Answer 1

Ecco le basi. La variabile conn contiene una normale classe di connessione JDBC già collegato al DB.

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

Le classi Oracle specifici come AQjmsQueueConnectionFactory sono nelle oracle.jms pacchetto.