Unschedule a Queue Propagation

Figure 9-20 Use Case Diagram: Unschedule a Queue Propagation

To refer to the table of all basic operations having to do with the Administrative Interface see: "Use Case Model: Administrative Interface -- Basic Operations"

Purpose:

Unscheduled previously scheduled propagation of messages from a queue to a destination identified by a specific dblink.

Usage Notes

Not applicable.

Syntax

See Chapter 3, "AQ Programmatic Environments" for a list of available functions in each programmatic environment. Use the following syntax references for each programmatic environment:

• PL/SQL (DBMS_AQADM Package): Oracle8i Supplied PL/SQL Packages Reference DBMS_AQADM, UNSCHEDULE_PROPAGATION procedure

• Visual Basic (OO4O): There is no applicable syntax reference for this use case

• Java (JDBC): Oracle8i Supplied Java Packages Reference oracle.AQ) schedulePropagation

Examples

See Chapter 3, "AQ Programmatic Environments" for a list of available functions in each programmatic environment. Examples are provided in the following programmatic environments:

• PL/SQL (DBMS_AQADM): Unschedule a Propagation

• VB (OO4O): Example not provided.

• Java (JDBC): Unschedule a Queue propagation

PL/SQL (DBMS_AQADM): Unschedule a Propagation

Unschedule Propagation from Queue To Other Queues in the Same Database

/* Unschedule propagation from queue aq.q1def to other queues in the same 
   database */ 
EXECUTE DBMS_AQADM.UNSCHEDULE_PROPAGATION(queue_name => 'aq.q1def'); 

Unschedule Propagation from a Queue to other Queues in Another Database

/* Unschedule propagation from queue aq.q1def to other queues in another 
   database reached by the database link another_db.world */
EXECUTE DBMS_AQADM.UNSCHEDULE_PROPAGATION(
   Queue_name    =>   'aq.q1def', 
   Destination   =>   'another_db.world'); 

Java (JDBC): Unschedule a Queue propagation

/* Unschedule propagation from a queue to other queues in the same database */
public static void example(AQSession aq_sess) throws AQException
{
     AQQueue         queue;
     AQAgent         agent1;        
     AQAgent         agent2;        

     /* Get the queue object */
     queue = aq_sess.getQueue("AQ", "q1def");

     queue.unschedulePropagation(null);
}

/* Unschedule propagation from a queue to other queues in another database */
public static void example(AQSession aq_sess) throws AQException
{
     AQQueue         queue;
     AQAgent         agent1;        
     AQAgent         agent2;        

     /* Get the queue object */
     queue = aq_sess.getQueue("AQ", "q1def");

     queue.unschedulePropagation("another_db.world");
}