Oracle8i Advanced Queuing -- Contents

Use Case Diagrams

State Diagrams

Queuing - an Optimal Means of Handling Messages

Messages as the Crux of Business Events

Using Queues to Coordinate the Interchange of Messages

What Queuing Systems Must Provide

Two Contexts for Developing Queuing Applications

Two Models for Queuing Messages

Point-to-Point Model

Publish-Subscribe Model

Features of Advanced Queuing (AQ)

Elements of Advanced Queuing (Native AQ)

Recipient and Subscription Lists

Rule

Rule Based Subscriber

Queue Monitor

Reference to Demos

Data Structures

Object Name

Type name

Agent

AQ Recipient List Type

AQ Agent List Type

AQ Subscriber List Type

Enumerated Constants in the Administrative Interface

Enumerated Constants in the Operational Interface

Issues and Considerations

INIT.ORA Parameter

Java Components - oracle.AQ

Location of Java AQ Classes

Programmatic Environments for Accessing AQ

Using PL/SQL (DBMS_AQADM and DBMS_AQ Packages) to Access AQ

Using Visual Basic (OO4O) to Access AQ

For More Information

Using OCI to Access AQ

Examples

Using AQ Java (oracle.AQ) Classes to Access AQ

Accessing Java AQ Classes

Advanced Queuing Examples

Managing Java AQ API

Using Oracle Java Messaging Service (JMS) to Access AQ

Standard JMS Features

Oracle JMS Extensions

Accessing Standard and Oracle JMS

For More Information

Comparing AQ Programmatic Environments

AQ Administrative Interfaces

AQ Operational Interfaces

Migrating Queue Tables (Import-Export)

Exporting Queue Table Data

Importing Queue Table Data

Security

Security with 8.0 and 8.1 Compatible Queues

Privileges and Access Control

Roles

Administrator Role

User Role

Access to AQ Object Types

OCI Applications

Propagation

Usage Notes

Example: To Upgrade An 8.0 Queue Table To A 8.1-Compatible Queue Table

Enterprise Manager Support

Protocols

Sample DBA Actions as Preparation for Working with AQ

Current Restrictions

Auto-commit features in DBMS_AQADM package

Collection Types in Message Payloads

Object Type Payload Support in AQ Java API

Synonyms on Queue Tables and Queue

Pluggable Tablespace does not Work For 8.0 Compatible Multiconsumer Queues

Tablespace point-in-time recovery

Propagation from Object Queues

Non-Persistent Queues

Compatibility

Performance

Table and index structures

Throughput

Availability

Scalability

Propagation Issues

Guidelines for Debugging AQ Propagation Problems

Modeling Queue Entities

Basic Queuing

Illustrating Basic Queuing

Illustrating Client-Server Communication Using AQ

Multiple-Consumer Dequeuing of the Same Message

Illustrating Multiple-Consumer Dequeuing of the Same Message

Illustrating Dequeuing of Specified Messages by Specified Recipients

Illustrating the Implementation of Workflows using AQ

Illustrating the Implementation of Publish/Subscribe using AQ

Message Propagation

Illustration of Message Propagation

A Sample Application

General Features

System Level Access Control

Structured Payload

Queue Level Access Control

Non-Persistent Queues

Retention and Message History

Publish/Subscribe Support

Support for Oracle Parallel Server

Support for Statistics Views

ENQUEUE Features

Subscriptions and Recipient Lists

Priority and Ordering of Messages

Time Specification: Delay

Time Specification: Expiration

Message Grouping

DEQUEUE Features

Dequeue Methods

Multiple Recipients

Local and Remote Recipients

Message Navigation in Dequeue

Modes of Dequeuing

Optimization of Waiting for Arrival of Messages

Asynchronous Notifications

Retry with Delay Interval

Exception Handling

Rule-based Subscription

Listen Capability

Propagation Features

Propagation

Propagation Scheduling

Propagation of Messages with LOB Attributes

Enhanced Propagation Scheduling Capabilities

Exception Handling During Propagation

Use Case Model: Administrative Interface -- Basic Operations

Create a Queue Table

PL/SQL (DBMS_AQADM Package): Create a Queue Table

VB (OO4O): Create a Queue Table

Java (JDBC): Create a Queue Table

Create a Queue Table [Set Storage Clause]

Alter a Queue Table

PL/SQL (DBMS_AQADM Package): Alter a Queue Table

Java (JDBC): Alter a Queue Table

Drop a Queue Table

PL/SQL (DBMS_AQADM Package): Drop a Queue Table

Java (JDBC): Drop a Queue Table

Create a Queue

PL/SQL (DBMS_AQADM): Create a Queue

Java (JDBC): Create a Queue

Create a Non-Persistent Queue

PL/SQL (DBMS_AQADM): Create a Non-Persistent Queue

Java (JDBC): Create a Non-persistent Queue

Alter a Queue

PL/SQL (DBMS_AQADM): Alter a Queue

Java (JDBC): Alter a Queue

Drop a Queue

PL/SQL (DBMS_AQADM): Drop a Queue

Java (JDBC): Drop a Queue

Start a Queue

PL/SQL (DBMS_AQADM Package): Start a Queue

Java (JDBC): Start a Queue

Stop a Queue

PL/SQL (DBMS_AQADM): Stop a Queue

Java (JDBC): Stop a Queue

Grant System Privilege

Purpose:

Usage Notes

Examples

PL/SQL (DBMS_AQADM): Grant System Privilege

Java (JDBC): Grant System Privilege

Revoke System Privilege

Using PL/SQL (DBMS_AQADM): Revoke System Privilege

Grant Queue Privilege

PL/SQL (DBMS_AQADM): Grant Queue Privilege

Java (JDBC): Grant Queue Privilege

Revoke Queue Privilege

PL/SQL (DBMS_AQADM): Revoke Queue Privilege

Java (JDBC): Revoke Queue Privilege

Add a Subscriber

PL/SQL (DBMS_AQADM): Add Subscriber

PL/SQL (DBMS_AQADM): Add Rule-Based Subscriber

Java (JDBC): Add a Subscriber

Alter a Subscriber

PL/SQL (DBMS_AQADM): Alter Subscriber

Java (JDBC): Alter a Subscriber

Remove a Subscriber

PL/SQL (DBMS_AQADM): Remove Subscriber

Java (JDBC): Remove a Subscriber

Schedule a Queue Propagation

PL/SQL (DBMS_AQADM): Schedule a Queue Propagation

Java (JDBC): Schedule a Queue propagation

Unschedule a Queue Propagation

PL/SQL (DBMS_AQADM): Unschedule a Propagation

Java (JDBC): Unschedule a Queue propagation

Verify a Queue Type

PL/SQL (DBMS_AQADM): Verify a Queue Type

Java (JDBC): Verify a Queue type

Alter a Propagation Schedule

PL/SQL (DBMS_AQADM): Alter a Propagation Schedule

Java (JDBC): Alter a Propagation Schedule

Enable a Propagation Schedule

PL/SQL (DBMS_AQADM): Enable a Propagation

Java (JDBC): Enable a Propagation Schedule

Disable a Propagation Schedule

PL/SQL (DBMS_AQADM): Disable a Propagation

Java (JDBC): Disable a Propagation Schedule

Use Case Model: Administrative Interface -- Views

Select All Queue Tables in Database

Select User Queue Tables

Select All Queues in Database

Select All Propagation Schedules

Select Queues for Which User Has Any Privilege

Select Queues for Which User Has Queue Privilege

Select Messages in Queue Table

Select Queue Tables in User Schema

Select Queues In User Schema

Select Propagation Schedules in User Schema

Select Queue Subscribers

Select Queue Subscribers and Their Rules

Select the Number of Messages in Different States for the Whole Database

Select the Number of Messages in Different States for Specific Instances

Use Case Model: Operational Interface -- Basic Operations

Enqueue a Message

Enqueue a Message [Specify Options]

Enqueue a Message [Specify Message Properties]

Enqueue a Message [Specify Message Properties [Specify Sender ID]]

Enqueue a Message [Add Payload]

PL/SQL (DBMS_AQ Package): Enqueue of Object Type Messages

Java (JDBC): Enqueue a message (add payload)

Visual Basic (OO4O): Enqueue a message

Listen to One (Many) Queue(s)

Listen to One (Many) Single-Consumer Queue(s)

Usage Notes

Syntax

Examples

PL/SQL (DBMS_AQ Package): Listen to Queue(s)

C (OCI): Listen to Single-Consumer Queue(s)

Listen to One (Many) Multi-Consumer Queue(s)

Usage Notes

Syntax

Examples

PL/SQL (DBMS_AQ Package): Listen to Queue(s)

C (OCI): Listen to Multi-Consumer Queue(s)

Dequeue a Message

Dequeue a Message from a Single-Consumer Queue [Specify Options]

PL/SQL (DBMS_AQ Package): Dequeue of Object Type Messages

Java (JDBC): Dequeue a message from a single consumer queue (specify options)

Visual Basic (OO4O): Dequeue a message

Dequeue a Message from a Multi-Consumer Queue [Specify Options]

Java (JDBC): Dequeue a message from a multi consumer queue (specify options)

Register for Notification

Register for Notification [Specify Subscription Name -- Single-Consumer Queue]

Register for Notification [Specify Subscription Name -- Multi-Consumer Queue]

Usage Notes

Syntax

Examples

C (OCI): Register for Notifications For Single-Consumer and Multi-Consumer Queries

A Sample Application

General Features

JMS Connection and Session

JMS Destinations - Queue and Topic

System Level Access Control

Destination Level Access Control

Retention and Message History

Support for Oracle Parallel Server

Support for Statistics Views

Structured Payload/Message Types

Payload Used by JMS Examples

Point-to-Point Model Features

Publish-Subscribe Model Features

Message Producer Features

Priority and Ordering of Messages

Time Specification - Delay

Time Specification - Expiration

Message Grouping

Message Consumer Features

Receiving Messages

Message Navigation in Receive

Modes for Receiving Messages

Retry With Delay Interval

Asynchronously Receiving Message Using Message Listener

AQ Exception Handling

Propagation

Remote Subscribers

Scheduling Propagation

Enhanced Propagation Scheduling Capabilities

Exception Handling During Propagation

Use Case Model: JMS Administrative Interface -- Basic Operations

Use Case Model Diagram: JMS Administrative Interface -- Basic Operations

Point-to-Point - Two Ways to Create a Queue Connection Factory

Get a Queue Connection Factory with JDBC URL

Get a Queue Connection Factory with JDBC Connection Parameters

Publish-Subscribe - Two Ways to Create a Topic Connection Factory

Get a Topic Connection Factory with JDBC URL

Get a Topic Connection Factory with JDBC Connection Parameters

Create a Queue Table

Create A Queue Table [Specify Queue Table Property]

Get a Queue Table

Specify Destination Properties

Point-to-Point - Create a Queue

Publish-Subscribe - Create a Topic

Grant System Privileges

Revoke System Privileges

Publish-Subscribe - Grant Topic Privileges

Publish-Subscribe - Revoke Topic Privileges

Point-to-Point: Grant Queue Privileges

Point-to-Point: Revoke Queue Privileges

Start a Destination

Stop a Destination

Alter a Destination

Drop a Destination

Schedule a Propagation

Enable a Propagation Schedule

Alter a Propagation Schedule

Disable a Propagation Schedule

Unschedule a Propagation

Use Case Model: Operational Interface -- Basic Operations

Use Case Model Diagram: Operational Interface (Point-to-Point)

Three Ways to Create a Queue Connection

Create a Queue Connection with Username/Password

Create a Queue Connection with Open JDBC Connection

Create a Queue Connection with Default Connection Factory Parameters

Create a Queue Session

Create a Queue Sender

Two Ways to Send Messages Using a Queue Sender

Send a Message Using a Queue Sender with Default Send Options

Send Messages Using a Queue Sender by Specifying Send Options

Two Ways to Create a Queue Browser for JMS Message Queues

Create a Queue Browser for Queues with Text, Stream, Objects, Bytes or Map Messages

Create a Queue Browser for Queues with Text, Stream, Objects, Bytes or Map Messages, Locking Messages while Browsing

Two Ways to Create a Queue Browser for Oracle Object Type (ADT) Messages Queues

Create a Queue Browser for Queues of Oracle Object Type (ADT) Messages

Create a Queue Browser for Queues of Oracle Object Type (ADT) Messages, Locking Messages While Browsing

Browse Messages Using a Queue Browser

Two Ways to Create a Queue Receiver

Create a Queue Receiver for Queues of Standard JMS Type Messages

Create a Queue Receiver for Queues of Oracle Object Type (ADT) Messages

Use Case Model: JMS Operational Interface -- Basic Operations (Publish-Subscribe)

Use Case Model Diagram: Operational Interface -- Basic Operations (Publish-Subscribe)

Three Ways to Create a Topic Connection

Create a Topic Connection with Username/Password

Create a Topic Connection with Open JDBC Connection

Create a Topic Connection with Default Connection Factory Parameters

Create a Topic Session

Create a Topic Publisher

Four Ways to Publish Messages Using a Topic Publisher

Publish a Message with Minimal Specification

Publish a Message Specifying Correlation and Delay

Publish a Message Specifying Priority and Time-To-Live

Publish Messages Specifying a Recipient List Overriding Topic Subscribers

Two Ways to Create a Durable Subscriber for a Topic of Standard JMS Type Messages

Create a Durable Subscriber for a JMS Topic Without Selector

Create a Durable Subscriber for a JMS Topic With Selector

Two Ways to Create a Durable Subscriber for a Topic of Oracle Object Type (ADT) Messages

Create a Durable Subscriber for an ADT Topic Without Selector

Create a Durable Subscriber for an ADT Topic With Selector

Two Ways to Create a Remote Subscriber

Create a Remote Subscriber for Topics of JMS Messages

Create a Remote Subscriber for Topics of Oracle Object Type (ADT) Messages

Two Ways to Unsubscribe a Durable Subscription

Unsubscribe a Durable Subscription for a Local Subscriber

Unsubscribe a Durable Subscription for a Remote Subscriber

Two Ways to Create a Topic Receiver

Create a Topic Receiver for a Topic of Standard JMS Type Messages

Create a Topic Receiver for a Topic of Oracle Object Type (ADT) Messages

Use Case Model: JMS Operational Interface -- Basic Operations (Shared Interfaces)

Start a JMS Connection

Get the JMS Connection from a Session

Commit All Operations in a Transacted Session

Rollback All Operations in a Transacted Session

Get the Underlying JDBC Connection from a JMS Session

Create a Bytes Message

Create a Map Message

Create a Stream Message

Create an Object Message

Create a Text Message

Create an ADT Message

Specify Message Correlation ID

Specify JMS Message Property

Usage Notes

Specify Message Property as Boolean

Specify Message Property as String

Specify Message Property as Int

Specify Message Property as Double

Specify Message Property as Float

Specify Message Property as Byte

Usage Notes

Syntax

Examples

Specify Message Property as Long

Specify Message Property as Short

Specify Message Property as Object

Set Default TimeToLive for All Messages Sent by a Message Producer

Set Default Priority for All Messages Sent by a Message Producer

Create an AQjms Agent

Two Ways to Receive a Message Synchronously Using a Message Consumer

Receive a Message Using a Message Consumer by Specifying Timeout

Receive a Message Using a Message Consumer Without Waiting

Specify the Navigation Mode for Receiving Messages

Two Ways to Specify a Message Listener to Receive a Message Asynchronously

Specify a Message Listener at the Message Consumer

Specify a Message Listener at the Session

Get the Correlation ID of a Message

Two Ways to Get the Message ID of a Message

Get the Message ID of a Message as Bytes

Get the Message ID of a Message as a String

Get the JMS Message Property

Get the Message Property as a Boolean

Get the Message Property as a String

Get the Message Property as Int

Get the Message Property as Double

Get the Message Property as Float

Get the Message Property as Byte

Get the Message Property as Long

Get the Message Property as Short

Get the Message Property as Object

Close a Message Producer

Close a Message Consumer

Stop a JMS Connection

Close a JMS Session

Close a JMS Connection

Get the Error Code for the JMS Exception

Get the Error Number for the JMS Exception

Get the Error Message for the JMS Exception

Get the Exception Linked to the JMS Exception

Print the Stack Trace for the JMS Exception

Create Queue Tables and Queues

Create a Queue Table and Queue of Object Type

Create a Queue Table and Queue of Raw Type

Create a Prioritized Message Queue Table and Queue

Create a Multiple-Consumer Queue Table and Queue

Create a Queue to Demonstrate Propagation

Setup for Java AQ Examples

Create an Java AQ Session

Create a Queue Table and Queue Using Java

Create a Queue and Start Enqueue/Dequeue Using Java

Create a Multi-Consumer Queue and Add Subscribers Using Java

Enqueue and Dequeue Of Messages

Enqueue and Dequeue of Object Type Messages Using PL/SQL

Enqueue and Dequeue of Object Type Messages Using Pro*C/C++

Enqueue and Dequeue of Object Type Messages Using OCI

Enqueue and Dequeue of Object Type Messages (CustomDatum interface) Using Java

Enqueue and Dequeue of Object Type Messages (using SQLData interface) Using Java

Enqueue and Dequeue of RAW Type Messages Using PL/SQL

Enqueue and Dequeue of RAW Type Messages Using Pro*C/C++

Enqueue and Dequeue of RAW Type Messages Using OCI

Enqueue of RAW Messages using Java

Dequeue of Messages Using Java

Dequeue of Messages in Browse Mode Using Java

Enqueue and Dequeue of Messages by Priority Using PL/SQL

Enqueue of Messages with Priority Using Java

Dequeue of Messages after Preview by Criterion Using PL/SQL

Enqueue and Dequeue of Messages with Time Delay and Expiration Using PL/SQL

Enqueue and Dequeue of Messages by Correlation and Message ID Using Pro*C/C++

Enqueue and Dequeue of Messages by Correlation and Message ID Using OCI

Enqueue and Dequeue of Messages to/from a Multiconsumer Queue Using PL/SQL

Enqueue and Dequeue of Messages to/from a Multiconsumer Queue using OCI

Enqueue and Dequeue of Messages Using Message Grouping Using PL/SQL

Enqueuing and Dequeuing Object Type Messages That Contain LOB Attributes Using PL/SQL

Enqueuing and Dequeuing Object Type Messages That Contain LOB Attributes Using Java

Propagation

Enqueue of Messages for remote subscribers/recipients to a Multiconsumer Queue and Propagation Scheduling Using PL/SQL

Manage Propagation From One Queue To Other Queues In The Same Database Using PL/SQL

Manage Propagation From One Queue To Other Queues In Another Database Using PL/SQL

Unscheduling Propagation Using PL/SQL

Drop AQ Objects

Revoke Roles and Privileges

Deploy AQ with XA

AQ and Memory Usage

Create_types.sql : Create Payload Types and Queues in Scott's Schema

Enqueue Messages (Free Memory After Every Call) Using OCI

Enqueue Messages (Reuse Memory) Using OCI

Dequeue Messages (Free Memory After Every Call) Using OCI

Dequeue Messages (Reuse Memory) Using OCI

Oracle JMSClasses (part 1)

Oracle JMS Classes (part 2)

Oracle JMS Classes (part 3)

Oracle JMS Classes (part 4)

Oracle JMS Classes (part 5)

Oracle JMS Classes (part 6)

Oracle JMS Classes (part 6 continued)

Oracle JMS Classes (part 7)

Oracle JMS Classes (part 8)

Oracle JMS Classes (part 9)

Oracle JMS Classes (part 10)

Oracle JMS Classes (part 10 continued)

Interface - javax.jms.BytesMessage

Interface - javax.jms.Connection

Interface - javax.jms.ConnectionFactory

Interface - javax.jms.ConnectionMetaData

Interface - javax.jms.DeliveryMode

Interface - javax.jms.Destination

Interface - javax.jms.MapMessage

Interface - javax.jms.Message

Interface - javax.jms.MessageConsumer

Interface - javax.jms.MessageListener

Interface - javax.jms.MessageProducer

Interface - javax.jms.ObjectMessage

Interface - javax.jms.Queue

Interface - javax.jms.QueueBrowser

Interface - javax.jms.QueueConnection

Interface - javax.jms.QueueConnectionFactory

Interface - javax.jms.QueueReceiver

Interface - javax.jms.QueueSender

Interface - javax.jms.QueueSession

Interface - javax.jms.Session

Interface - javax.jms.StreamMessage

Interface - javax.jms.TextMessage

Interface - javax.jms.Topic

Interface - javax.jms.TopicConnection

Interface - javax.jms.TopicConnectionFactory

Interface - javax.jms.TopicPublisher

Interface - javax.jms.TopicSession

Interface - javax.jms.TopicSubscriber

Exception javax.jms.InvalidDestinationException

Exception javax.jms.InvalidSelectorException

Exception javax.jms.JMSException

Exception javax.jms.MessageEOFException

Exception javax.jms.MessageFormatException

Exception javax.jms.MessageNotReadableException

Exception javax.jms.MesageNotWriteableException

Interface - oracle.jms.AdtMessage

Interface - oracle.jms.AQjmsQueueReceiver

Interface - oracle.jms.AQjmsQueueSender

Interface - oracle.jms.AQjmsTopicPublisher

Interface - oracle.jms.TopicReceiver

Interface - oracle.jms.AQjmsTopicSubscriber

Interface - oracle.jms.AQjmsTopicReceiver

Class - oracle.jms.AQjmsAdtMessage

Class - oracle.jms.AQjmsAgent

Class - oracle.jms.AQjmsBytesMessage

Class - oracle.jms.AQjmsConnection

Interface - oracle.jms.AQjmsConnectionMetadata

Class - oracle.jms.AQjmsConstants

Interface - oracle.jms.AQjmsConsumer

Class - oracle.jms.AQjmsDestination

Class - oracle.jms.AQjmsDestinationProperty

Class - oracle.jms.AQjmsFactory

Class - oracle.jms.AQjmsMapMessage

Class - oracle.jms.AQjmsMessage

Class - oracle.jms.AQjmsObjectMessage

Class - oracle.jms.AQjmsOracleDebug

Class - oracle.jms.AQjmsProducer

Class - oracle.jms.AQjmsQueueBrowser

Class - AQjmsQueueConnectionFactory

Class - oracle.jms.AQjmsSession

Class - oracle.jms.AQjmsStreamMessage

Class - oracle.jms.AQjmsTextMessage

Class - oracle.jms.AQjmsTopicConnectionFactory

Exception oracle.jms.AQjmsException

Exception oracle.jms.AQjmsInvalidDestinationException

Exception oracle.jms.AQjmsInvalidSelectorException

Exception oracle.jms.AQjmsMessageEOFException

Exception oracle.jms.AQjmsMessageFormatException

Exception oracle.jms.AQjmsMessageNotReadableException

Exception oracle.jms.AQjmsMesssageNotWriteableException

Interface - oracle.AQ.AQQueueTable

Class - oracle.AQ.AQQueueTableProperty

tkaqdoca.sql: Script to Create Users, Objects, Queue Tables, Queues & Subscribers

tkaqdocd.sql: Examples of Administrative and Operational Interfaces

tkaqdoce.sql: Operational Examples

tkaqdocp.sql: Examples of Operational Interfaces

tkaqdocc.sql: Clean-Up Script

Contents

Title and Copyright Information

Send Us Your Comments

Preface

1 What is Oracle Advanced Queuing?

2 Basic Components

3 AQ Programmatic Environments

4 Managing AQ

5 Advanced Topics

6 Frequently Asked Questions

7 Modeling and Design

8 A Sample Application Using AQ

9 Administrative Interface

10 Administrative Interface: Views

11 Operational Interface: Basic Operations

12 Creating Applications Using JMS

13 JMS Administrative Interface: Basic Operations

14 JMS Operational Interface: Basic Operations (Point-to-Point)

15 JMS Operational Interface: Basic Operations (Publish-Subscribe)

16 JMS Operational Interface: Basic Operations (Shared Interfaces)

A Oracle Advanced Queuing by Example

B Oracle JMS Interfaces, Classes and Exceptions

C Scripts for Implementing 'BooksOnLine'

D JMS Error Messages

Index