How to use Oracle Advanced Queuing (AQ) with a Java JMS application

-- Example: Create an object type for payload
CREATE OR REPLACE TYPE msg_type AS OBJECT (
  text_content  VARCHAR2(4000)
);
/
<p>-- Create queue table
BEGIN
DBMS_AQADM.CREATE_QUEUE_TABLE(
queue_table        =&gt; 'jms_queue_tab',
queue_payload_type =&gt; 'MSG_TYPE',
compatible         =&gt; '10.0'
);
END;
/</p><p>-- Create the queue
BEGIN
DBMS_AQADM.CREATE_QUEUE(
queue_name  =&gt; 'jms_queue',
queue_table =&gt; 'jms_queue_tab'
);
END;
/</p><p>-- Start the queue
BEGIN
DBMS_AQADM.START_QUEUE(queue_name =&gt; 'jms_queue');
END;
/</p>

import javax.jms.*;
import oracle.jms.AQjmsFactory;
import java.sql.Connection;
import java.sql.DriverManager;
<p>public class AQMessageSender {
public static void main(String[] args) throws Exception {
// Connect to Oracle DB
Connection dbConn = DriverManager.getConnection(
"jdbc:oracle:thin:@//localhost:1521/ORCL",
"username", "password");</p><pre class='brush:php;toolbar:false;'>// Get JMS connection
QueueConnectionFactory qcf = AQjmsFactory.getQueueConnectionFactory(dbConn);
QueueConnection qc = qcf.createQueueConnection();
QueueSession qs = qc.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

// Access the queue
Queue queue = ((AQjmsSession)qs).getQueue("username", "jms_queue");

// Send message
QueueSender sender = qs.createSender(queue);
TextMessage msg = qs.createTextMessage("Hello from JMS via Oracle AQ");
sender.send(msg);
System.out.println("Message sent.");

// Clean up
sender.close();
qs.close();
qc.close();
dbConn.close();

} }

public class AQMessageReceiver {
  public static void main(String[] args) throws Exception {
    Connection dbConn = DriverManager.getConnection(
        "jdbc:oracle:thin:@//localhost:1521/ORCL",
        "username", "password");
<pre class='brush:php;toolbar:false;'>QueueConnectionFactory qcf = AQjmsFactory.getQueueConnectionFactory(dbConn);
QueueConnection qc = qcf.createQueueConnection();
QueueSession qs = qc.createQueueSession(false, Session.AUTO_ACKNOWLEDGE);

Queue queue = ((AQjmsSession)qs).getQueue("username", "jms_queue");
QueueReceiver receiver = qs.createReceiver(queue);

qc.start(); // Required to enable message delivery

Message msg = receiver.receive(3000); // Wait up to 3 seconds
if (msg != null &amp;&amp; msg instanceof TextMessage) {
  System.out.println("Received: " + ((TextMessage) msg).getText());
} else {
  System.out.println("No message received.");
}

receiver.close();
qs.close();
qc.close();
dbConn.close();

} }