ITPub博客

首页 > Linux操作系统 > Linux操作系统 > Advanced queuing test (3)

Advanced queuing test (3)

原创 Linux操作系统 作者:dragondb 时间:2019-05-17 09:03:05 0 删除 编辑

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/ ,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2003-05-05

  • 博文量
    98
  • 访问量
    94093