7. Queue Propagation
SQL> BEGIN
2 dbms_aqadm.create_queue_table(
3 queue_table => 'bzcardorders_prpqt'
4 ,comment => 'Business Card Orders queue table for Propogation'
5 ,multiple_consumers => true
6 ,queue_payload_type => 'bz_adm.bzcardorder_type'
7 );
8 END;
9 /
PL/SQL procedure successfully completed.
SQL> BEGIN
2 dbms_aqadm.create_queue (
3 queue_name => 'bzcardorders_prpq',
4 queue_table => 'bzcardorders_prpqt');
5 END;
6 /
PL/SQL procedure successfully completed.
SQL> BEGIN
2 dbms_aqadm.start_queue (
3 queue_name => 'bzcardorders_prpq');
4 END;
5 /
PL/SQL procedure successfully completed.
SQL> BEGIN
2 dbms_aqadm.add_subscriber(queue_name => 'bzcardorders_prpq'
3 ,subscriber => sys.aq$_agent('RUSH',NULL,NULL)
4 );
5 END;
6 /
PL/SQL procedure successfully completed.
SQL> BEGIN
2 dbms_aqadm.schedule_propagation(queue_name => 'bzcardorders_prpq');
3 END;
4 /
PL/SQL procedure successfully completed.
SQL> DECLARE
2 enqueue_options dbms_aq.enqueue_options_t;
3 message_properties dbms_aq.message_properties_t;
4 message_handle raw(16);
5 BEGIN
6
7 dbms_aq.enqueue(queue_name => 'bzcardorders_prpq'
8 ,enqueue_options => enqueue_options
9 ,message_properties => message_properties
10 ,payload => bz_adm.bzcardorder_type(116,'RUSH','RUSH','Normal')
11 ,msgid => message_handle
12 );
13 commit;
14 END;
15 /
PL/SQL procedure successfully completed.
来自 “ ITPUB博客 ” ,链接:https://blog.itpub.net/45259/viewspace-240020/ ,如需转载,请注明出处,否则将追究法律责任。