Posts

Showing posts with the label aq

enqueue dequeue sql script

Enqueue Message DECLARE enqueue_options DBMS_AQ.enqueue_options_t; message_properties DBMS_AQ.message_properties_t; msg_handle RAW (16); ipmsg ip_message_type; xml_clob CLOB; msg_id NUMBER (10); subscribers DBMS_AQ.aq$_recipient_list_t; BEGIN xml_clob := ''; subscribers (1) := SYS.aq$_agent (' ' , NULL , NULL); message_properties.recipient_list := subscribers; DBMS_AQ.enqueue (queue_name => ' ' , enqueue_options => enqueue_options , message_properties => message_properties , payload => xml_clob , msgid => msg_handle); COMMIT; END; Dequeue Message DECLARE dequeue_options DBMS_AQ.dequeue_options_t; message_properties DBMS_AQ.message_properties_t; message_handle RAW (16); xml_clob CLOB; BEGIN dequeue_options.consumer_name := ' '; dequeue_options.dequeue_mode := DBMS_AQ.remove; -- Only if you want to remove message dequeue_options.navigation := DBMS_AQ.next_message; dequeue_options.WAIT := DBMS_AQ.forever; DBMS_AQ.dequeue (queue_name => ...