Mega Code Archive

 

Categories / Oracle PLSQL Tutorial / System Packages

 

DBMS_AQ ENQUEUE_OPTIONS_T

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_enqopts   DBMS_AQ.ENQUEUE_OPTIONS_T;   4      v_msg_prop  DBMS_AQ.MESSAGE_PROPERTIES_T;   5      v_msgid RAW(16);   6      v_ctr       INTEGER ;   7  BEGIN   8      FOR v_ctr IN 1..10 LOOP   9        v_msg := myTable('Message '|| v_ctr,  10               'test message data '|| v_ctr, sysdate) ;  11        DBMS_AQ.ENQUEUE(queue_name => 'test_q',  12          enqueue_options => v_enqopts,  13          message_properties => v_msg_prop,  14          payload => v_msg,  15          msgid => v_msgid);  16      END LOOP ;  17      COMMIT;  18  END ;  19  / PL/SQL procedure successfully completed.