Create Connection, Session, Message 

Create a Connection 

N/A 

Create JDBC connection 

OCIServerAttach 

OpenDatabase 

AQjmsQueueConnectionFactory.createQueueConnection

AQjmsTopicConnectionFactory.createTopicConnecion 

Create a Session 

N/A 

AQDriverManager.createAQSession 

OCISessionBegin 

QueueConnection.createQueueSession

TopicConnecion.createTopicSession 

Create a RAW Message 

Use SQL RAW type for message 

AQQueue.createMessage

Set AQRawPayload in message 

Use OCIRaw for Message 

CreateOraAQMsg

with msgtype

ORATYPE_RAW 

Not supported 

Create a Message with Structured Data 

Use SQL ADT type for message 

AQQueue.createMessage

Set AQObjectPayload in message 

Use SQL ADT type for message 

CreateOraAQMsg

with

ORATYPE_OBJECT and typename as SQL ADT type of the payload

Session.createTextMessage

Session.createObjectMessage

Session.createMapMessage

Session.createBytesMessage

Session.createStreamMessage

AQjmsSession.createAdtMessage 

Create a Message Producer 

N/A 

N/A 

N/A 

N/A 

QueueSession.createSender

TopicSession.createPublisher 

Enqueue Messages to a Single Consumer Queue: Point-to-Point Model 

Enqueue a Message to a single-consumer queue 

DBMS_AQ.enqueue 

AQQueue.enqueue 

OCIAQEnq 

OraAP.Enqueue 

QueueSender.send 

Enqueue a Message to a queue - specify visibility options 

DBMS_AQ.enqueue

Specify visibility in ENQUEUE_OPTIONS 

AQQueue.enqueue

Specify visibility in AQEnqueueOption 

OCIAQEnq

Specify OCI_ATTR_VISIBILITY in OCIAQEnqOptions 

OraAQ.Enqueue

Specify visibility property in OraAQ 

Not supported 

Enqueue a Message to a single-consumer queue - specify message properties - priority, expiration 

DBMS_AQ.enqueue

Specify priority, expiration in MESSAGE_PROPERTIES 

AQQueue.enqueue

Specify priority, expiration in AQMessageProperty 

OCIAQEnq

Specify

OCI_ATTR_PRIORITY, OCI_ATTR_EXPIRATION in OCIAQMsgProperties 

OraAQ.Enqueue

Specify Priority and Expiration properties in OraAQMsg 

Specify priority and TimeToLive during QueueSender.send OR MessageProducer.setTimeToLive & MessageProducer.setPriority

followed by QueueSender.send 

Enqueue a Message to a single-consumer Queue - specify message properties - correlationID, delay, exception queue 

DBMS_AQ.enqueue

Specify correlation, delay, exception_queue in MESSAGE_PROPERTIES 

AQQueue.enqueue

Specify correlation, delay, exception queue in AQMessageProperty 

OCIAQEnq

Specify OCI_ATTR_CORRELATION, OCI_ATTR_DELAY, OCI_ATTR_EXCEPTION_QUEUE in OCIAQMsgProperties 

OraAQ.Enqueue

Specify Correlation, Delay, ExceptionQueue properties in OraAQMsg 

Message.setJMSCorrelationID

Delay and exception queue specified as provider specific message properties

JMS_OracleDelay

JMS_OracleExcpQ

followed by QueueSender.send 

Enqueue a Message to a single-consumer Queue - specify Message Properties (user-defined) 

Not supported

Properties should be part of payload 

Not supported

Properties should be part of payload 

Not supported

Properties should be part of payload 

Not supported

Properties should be part of payload 

Message.setIntProperty

Message.setStringProperty

Message.setBooleanProperty etc. followed by

QueueSender.send 

Publish Messages to a Multi-Consumer Queue/Topic - Publish-Subscriber Model 

Publish a Message to a Multi-consumer queue/Topic (using default subscription list) 

DBMS_AQ.enqueue

Set recipient_list to NULL in MESSAGE_PROPERTIES 

AQQueue.enqueue

Set recipient_list to NULL in AQMessageProperty 

OCIAQEnq

Set OCI_ATTR_RECIPIENT_LIST to NULL in OCIAQMsgProperties 

OraAQ.Enqueue 

TopicPublisher.publish 

Publish a Message to a Multi-consumer queue/Topic (using specific recipient list)

See footnote-1 

DBMS_AQ.enqueue

Specify recipient list in MESSAGE_PROPERTIES 

AQQueue.enqueue

Specify recipient_list in AQMessageProperty 

OCIAQEnq

Specify OCI_ATTR_RECIPIENT_LIST in OCIAQMsgProperties 

OraAQ.Enqueue 

AQjmsTopicPublisher.pubish

Specify recipients as an array of AQjmsAgent 

Publish a Message to a multi-consumer Queue/Topic - specify message properties - priority, expiration 

DBMS_AQ.enqueue

Specify priority, expiration in MESSAGE_PROPERTIES 

AQQueue.enqueue

Specify priority, expiration in AQMessageProperty 

OCIAQEnq

Specify OCI_ATTR_PRIORITY, OCI_ATTR_EXPIRATION in OCIAQMsgProperties 

OraAQ.Enqueue

Specify Priority and Expiration properties in OraAQMsg 

Specify priority and TimeToLive during TopicPublisher.publish OR MessageProducer.setTimeToLive & MessageProducer.setPriority followed by

TopicPublisher.publish 

Publish a Message to a multi-consumer queue/topic - specify send options - correlationID, delay, exception queue 

DBMS_AQ.enqueue

Specify correlation, delay, exception_queue in MESSAGE_PROPERTIES 

AQQueue.enqueue

Specify correlation, delay, exception queue in AQMessageProperty

OCIAQEnq

Specify OCI_ATTR_CORRELATION, OCI_ATTR_DELAY, OCI_ATTR_EXCEPTION_QUEUE in OCIAQMsgProperties 

OraAQ.Enqueue

Specify Correlation, Delay, ExceptionQueue properties in OraAQMsg 

Message.setJMSCorrelationID

Delay and exception queue specified as provider specific message properties

JMS_OracleDelay

JMS_OracleExcpQ

followed by TopicPublisher.publish 

Publish a Message to a topic- specify Message Properties (user-defined) 

Not supported

Properties should be part of payload 

Not supported

Properties should be part of payload 

Not supported

Properties should be part of payload 

Not supported

Properties should be part of payload 

Message.setIntProperty

Message.setStringProperty

Message.setBooleanProperty etc. followed by

TopicPublisher.publish 

Subscribing for Messages in a Multi Consumer Queue/Topic - Publish Subscribe Model 

Add a Subscriber 

See administrative interfaces 

See administrative interfaces 

Not supported 

Not supported 

TopicSession.createDurableSubscriber

AQjmsSession.createDurableSubscriber 

Alter a Subscriber 

See administrative interfaces 

See administrative interfaces 

Not supported 

Not supported 

TopicSession.createDurableSubscriber

AQjmsSession.createDurableSubscriber

using the new selector 

Remove a Subscriber 

See administrative interfaces 

See administrative interfaces 

Not supported 

Not supported 

AQjmsSession.unsubscriber

Browse Messages In a Queue 

Browse messages in a Queue/Topic 

DBMS_AQ.dequeue

Set dequeue_mode to BROWSE in DEQUEUE_OPTIONS 

AQQueue.dequeue

Set dequeue_mode to BROWSE in AQDequeueOption 

OCIAQDeq

Set OCI_ATTR_DEQ_MODE to BROWSE in OCIAQDeqOptions  

OraAQ.Dequeue

Set Dequeue Mode to ORAAQ_DQ_BROWSE in OraAQ 

QueueSession.createBrowser

QueueBrowser.getEnumeration

Not supported on Topics 

Browse messages in a Queue/Topic - locking messages while browsing 

DBMS_AQ.dequeue

Set dequeue_mode to LOCKED in DEQUEUE_OPTIONS 

AQQueue.dequeue

Set dequeue_mode to LOCKED in AQDequeueOption 

OCIAQDeq

Set OCI_ATTR_DEQ_MODE to LOCKED in OCIAQDeqOptions 

OraAQ.Dequeue

Specify DequeueMode as ORAAQ_DQ_LOCKED in OraAQ 

AQjmsSession.createBrowser - set locked to TRUE.

QueueBrowser.getEnumeration

Not supported on Topics

Receive Messages From a Queue/Topic  

Start a connection for receiving messages 

N/A 

N/A 

N/A 

N/A 

Connection.start 

Create a Message Consumer 

N/A 

N/A 

N/A 

N/A 

QueueSession.createQueueReceiver

TopicSession.createDurableSubscriber

AQjmsSession.createTopicReceiver 

Dequeue a message from a queue/topic - specify visibility 

DBMS_AQ.dequeue

Specify visibility in DEQUEUE_OPTIONS 

AQQueue.dequeue

Specify visibility in AQDequeueOption 

OCIAQDeq

Specify OCI_ATTR_VISIBILITY in OCIAQDeqOptions 

OraAQ.Dequeue

Specify Visible property in OraAQ 

Not supported 

Dequeue a message from a queue/topic - specify navigation mode 

DBMS_AQ.dequeue

Specify navigation in DEQUEUE_OPTIONS 

DBMS_AQ.dequeue

Specify navigation in AQDequeueOption 

OCIAQDeq

Specify OCI_ATTR_NAVIGATION in OCIAQDeqOptions 

OraAQ.Dequeue

Specify Navigation in OraAQ 

AQjmsQueueReceiver.setNavigationMode

AQjmsTopicSubscriber.setNavigationMode

AQjmsTopicReceiver.setNavigationMode 

Dequeue a message from a single consumer queue 

DBMS_AQ.dequeue

Set dequeue_mode to REMOVE in DEQUEUE_OPTIONS 

AQQueue.dequeue

Set dequeue_mode to REMOVE in AQDequeueOption 

OCIAQDeq

Set OCI_ATTR_DEQ_MODE to REMOVE in OCIAQDeqOptions 

OraAQ.Dequeue

Specify DequeueMode as ORAAQ_DQ_REMOVE in OraAQ 

QueueReceiver.receive or

QueueReceiver.receiveNoWait or

AQjmsQueueReceiver.receiveNoData 

Dequeue a message from a multi-consumer Queue/Topic (using subscription name)¹ 

DBMS_AQ.dequeue

Set dequeue_mode to REMOVE and Set consumer_name to subscription name in DEQUEUE_OPTIONS 

AQQueue.dequeue

Set dequeue_mode to REMOVE and Set consumer_name to subscription name in AQDequeueOption 

OCIAQDeq

Set OCI_ATTR_DEQ_MODE to REMOVE and Set OCI_ATTR_CONSUMER_NAME to subscription name in OCIAQDeqOptions 

OraAQ.Dequeue

Specify DequeueMode as ORAAQ_DQ_REMOVE in OraAQ

Set Consumer as subscription name in OraAQ 

Create a durable TopicSubscriber on the Topic using the subscription name, then

TopicSubscriber.receive or

TopicSubscriber.receiveNoWait or

AQjmsTopicSubscriber.receiveNoData 

Dequeue a message from a multi-consumer Queue/Topic (using recipient name)² 

DBMS_AQ.dequeue

Set dequeue_mode to REMOVE and Set consumer_name to recipient name in DEQUEUE_OPTIONS 

AQQueue.dequeue

Set dequeue_mode to REMOVE and Set consumer_name to recipient name inAQDequeueOption 

OCIAQDeq

Set OCI_ATTR_DEQ_MODE to REMOVE and Set OCI_ATTR_CONSUMER_NAME to recipient name in OCIAQDeqOptions 

OraAQ.Dequeue

Specify DequeueMode as ORAAQ_DQ_REMOVE in OraAQ

Set Consumer as subscription name in OraAQ 

Create a TopicReceiver on the Topic using the recipient name, then

AQjmsSession.createTopicReceiver

AQjmsTopicReceiver.receive or

AQjmsTopicReceiver.receiveNoWait or

AQjmsTopicReceiver.receiveNoData

Register to Receive Messages Asynchronously From a Queue/Topic 

Receive messages Asynchronously from a single-consumer queue 

Not supported 

Not supported 

OCISubscriptionRegister

Specify queue_name as subscription name

OCISubscriptionEnable 

OraAQ.MonitorStart 

Create a QueueReceiver on the queue, then

QueueReceiver.setMessageListener 

Receive messages Asynchronously from a multi-consumer queue/Topic 

Not supported 

Not supported 

OCISubscriptionRegister

Specify queue:OCI_ATTR_CONSUMER_NAME as subscription name

OCISubscriptionEnable 

OraAQ.MonitorStart

Specify

Consumer as subscription name in OraAQ 

Create a TopicSubscriber or TopicReceiver on the topic, then

TopicSubscriber.setMessageListener

TopicReceiver.setMessageListener 

Listen for messages on multiple Queues/Topics 

Listen for messages on one (many) single-consumer queues 

DBMS_AQ.listen

Use agent_name as NULL for all agents in agent_list 

Not supported 

OCIAQListen

Use agent_name as NULL for all agents in agent_list 

Not supported 

Create multiple QueueReceivers on a QueueSession, then

QueueSession.setMessageListener 

Listen for messages on one(many) multi-consumer queues/Topics 

DBMS_AQ.listen

Specify agent_name for all agents in agent_list 

Not supported 

OCIAQListen

Specify agent_name for all agents in agent_list 

Not supported 

Create multiple TopicSubscribers or TopicReceivers on a TopicSession, then

TopicSession.setMessageListener