DeQueue

mail@pastecode.io avatar
unknown
sql
a year ago
715 B
3
Indexable
Never
PROCEDURE DeQueue(p_QueueName in varchar2, p_Msg_out out varchar2)
is
   queueopts DBMS_AQ.DEQUEUE_OPTIONS_T;
   msgprops DBMS_AQ.MESSAGE_PROPERTIES_T;
   msgid RAW(16); /* defined in aq.spp */
   my_msg message_type;
      p_Error varchar2(200);
      th boolean;
Begin
  queueopts.visibility := DBMS_AQ.on_commit;
DBMS_AQ.DEQUEUE (p_QueueName,
      queueopts,
      msgprops,
      my_msg,
      msgid);
p_Msg_out:=my_msg.text;
--Vudn sua ngay 01/07/2016 de sleep khi gui tin
--Sleep(0.01);

exception
    when others then
      RollBack;
       dbms_output.put_line(sqlerrm);
      p_Error := substr(sqlerrm, 1, 200);
      th  := commonfunctions_pkg.ghi_loi(p_Error +' DeQueue' );
End;