Mega Code Archive

 

Categories / Oracle PLSQL Tutorial / System Packages

 

DBMS_AQADM STOP_QUEUE

SQL> SQL> create or replace type myTable as object (   2      msg_identifier  VARCHAR2(25),   3      msg_body        VARCHAR2(100),   4      msg_date        DATE);   5  / SQL> SQL> DECLARE   2      v_msg       myTable;   3      v_deqopts   DBMS_AQ.DEQUEUE_OPTIONS_T;   4      v_msg_prop  DBMS_AQ.MESSAGE_PROPERTIES_T;   5      v_msgid RAW(16);   6      dq_timeout  EXCEPTION;   7      PRAGMA EXCEPTION_INIT(dq_timeout, -25228) ;   8   9  BEGIN  10      LOOP  11         v_deqopts.wait := 1 ;  12         DBMS_AQ.DEQUEUE(queue_name => 'test_q',  13          dequeue_options => v_deqopts,  14          message_properties => v_msg_prop,  15          payload => v_msg,  16          msgid => v_msgid);  17         DBMS_OUTPUT.PUT_LINE(v_msg.msg_identifier ||' Data: '  18          ||v_msg.msg_body||'  Date: '||v_msg.msg_date);  19      END LOOP;  20  21      COMMIT ;  22  23  EXCEPTION  24      WHEN dq_timeout THEN NULL ;  25  END ;  26  / Message 1 Data: test message data 1  Date: 24-JUL-08 Message 2 Data: test message data 2  Date: 24-JUL-08 Message 3 Data: test message data 3  Date: 24-JUL-08 Message 4 Data: test message data 4  Date: 24-JUL-08 Message 5 Data: test message data 5  Date: 24-JUL-08 Message 6 Data: test message data 6  Date: 24-JUL-08 Message 7 Data: test message data 7  Date: 24-JUL-08 Message 8 Data: test message data 8  Date: 24-JUL-08 Message 9 Data: test message data 9  Date: 24-JUL-08 Message 10 Data: test message data 10  Date: 24-JUL-08 PL/SQL procedure successfully completed. SQL> SQL> BEGIN   2      DBMS_AQADM.STOP_QUEUE(queue_name => 'test_q');   3      DBMS_AQADM.DROP_QUEUE(queue_name => 'test_q');   4      DBMS_AQADM.DROP_QUEUE_TABLE(queue_table => 'test_q_table');   5  END;   6  / PL/SQL procedure successfully completed. SQL> SQL> drop type myTable ; Type dropped. SQL>