Enabling a Propagation Schedule

Figure 9-27 Use Case Diagram: Enable a Propagation Schedule

Text description of the illustration adq09qad34.gif

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

To enable a previously disabled propagation schedule.

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): Oracle9i Supplied PL/SQL Packages and Types Reference DBMS_AQADM, ENABLE_PROPAGATION_SCHEDULE procedure

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

• Java (JDBC): Oracle9i Supplied Java Packages Reference oracle.AQ, enablePropagationSchedule

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): Enabling a Propagation

• VB (OO4O): Example not provided.

• Java (JDBC): Enabling a Propagation Schedule

PL/SQL (DBMS_AQADM): Enabling a Propagation

Enable Propagation from a Queue to Other Queues in the Same Database

/* Enable propagation from queue aq.q1def to other queues in the same 
   database */
EXECUTE DBMS_AQADM.ENABLE_PROPAGATION_SCHEDULE(
   Queue_name   =>   'aq.q1def');

Enable Propagation from a Queue to Queues in Another Database

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

Java (JDBC): Enabling a Propagation Schedule

/* Enable 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.enablePropagationSchedule(null);	
}

/* Enable 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.enablePropagationSchedule("another_db.world");
}