Oracle Advanced Queuing 之03(訂閱&通知)
阿新 • • 發佈:2020-11-14
1.建立佇列及隊列表且啟動之 aq_admin login
begin --Create a table for queues dbms_aqadm.create_queue_table (queue_table=>'aq_msg_qtab2',queue_payload_type=>'AQ_ADMIN.AQ_MSG_TYPE',multiple_consumers => true); --Create a test queue dbms_aqadm.create_queue (queue_name => 'aq_msg_queue2', queue_table => 'aq_msg_qtab2'); --Start the queue dbms_aqadm.start_queue (queue_name => 'aq_msg_queue2'); end; / begin dbms_aqadm.grant_queue_privilege (privilege => 'ALL',queue_name => 'AQ_ADMIN.AQ_MSG_QUEUE2',grantee => 'AQ_USER',grant_option => FALSE); end;
2.建立訂閱&註冊回撥(回撥過程的建立參照上節) aq_admin login
begin -- Configure the demo subscriber. dbms_aqadm.add_subscriber (queue_name => 'aq_msg_queue2',subscriber => sys.aq$_agent(name => 'subscriber_xag',address => null,protocol => 0)); -- Register the procedure for dequeuing the messages received. dbms_aq.register( sys.aq$_reg_info_list( sys.aq$_reg_info('AQ_ADMIN.AQ_MSG_QUEUE2:SUBSCRIBER_XAG',dbms_aq.namespace_aq, 'plsql://AQ_USER.CALL_BACK_PCK.AQ_MSG_QUEUE1',hextoraw('FF')) ), 1); end; /
3.入隊 aq_user login
select count(1) from aq_admin.aq_msg_qtab2; ------------------------------------------------------- 0 declare v_queue_name varchar2(50); v_enqueue_options dbms_aq.enqueue_options_t; v_message_properties dbms_aq.message_properties_t; v_message_handle raw(16); v_aq_msg aq_admin.aq_msg_type; begin v_queue_name:='aq_admin.aq_msg_queue2'; v_aq_msg := aq_admin.aq_msg_type (3,'none','none','a','content 3',sysdate); dbms_aq.enqueue(queue_name => v_queue_name,enqueue_options => v_enqueue_options,message_properties => v_message_properties,payload => v_aq_msg,msgid => v_message_handle); commit; end; select count(1) from aq_admin.aq_msg_qtab2; ------------------------------------------------------- 0
4.驗證回撥結果
select t.queue_name,t.received_time,t.consumer_name,t.content.msg_content,t.content.msg_create_time
from aq_msg_received t where 'content 3'=t.content.msg_content
-----------------------------------------------------------------------------------
QUEUE_NAME RECEIVED_TIME CONSUMER_NAME CONTENT.MSG_CONTENT CONTENT.MSG_CREATE_TIME
"AQ_ADMIN"."AQ_MSG_QUEUE2" 2020/11/11 23:16:38 SUBSCRIBER_XAG content 3 2020/11/11 23:16:38