RIB - To Move message from ERROR queue to Normal Queue

PT : RIB - Mover mensagem da ERROR queue para Normal Queue

EN :RIB - To Move  message from  ERROR queue to  Normal Queue

--
-- RIB QUEUES
--

-- check messages queues
select * from ETPRMPRCCHGFROMRPMTABLE  where deq_time is null
select count(0) from AQ$_ETPRMPRCCHGFROMRPMTABLE

BEGIN
dbms_aqadm.start_queue('AQ$_ETPRMPRCCHGFROMRPMTABLE_E',enqueue=>FALSE, dequeue=>TRUE);
END;
/

--
-- run it  until the  error queue have none records
--

DECLARE
  enqueue_options DBMS_AQ.enqueue_options_t;
  dequeue_options dbms_aq.dequeue_options_t;
  message_properties DBMS_AQ.message_properties_t;
  message_handle RAW(16);
  MESSAGE SYS.AQ$_JMS_MESSAGE;
BEGIN
  DBMS_AQ.DEQUEUE( queue_name => 'AQ$_ETPRMPRCCHGFROMRPMTABLE_E', dequeue_options => dequeue_options, message_properties => message_properties, payload => MESSAGE, msgid => message_handle);
  DBMS_AQ.ENQUEUE( queue_name => 'ETPRMPRCCHGFROMRPM', enqueue_options => enqueue_options, message_properties => message_properties, payload => MESSAGE, msgid => message_handle);
END;
/

commit;

BEGIN
dbms_aqadm.stop_queue('AQ$_ETPRMPRCCHGFROMRPMTABLE_E');
END;
/

--
-- JMS QUEUES - change messages from error queue into the normal
--

-- check messages queues
select * from NB_JMS_COSTCHG_TEXT where deq_time is null

BEGIN
dbms_aqadm.start_queue('RMSPRD.AQ$_NB_JMS_COSTCHG_TEXT_E',enqueue=>FALSE, dequeue=>TRUE);
END;
/

--
-- run it  until the  error queue have none records
--

DECLARE
  enqueue_options DBMS_AQ.enqueue_options_t;
  dequeue_options dbms_aq.dequeue_options_t;
  message_properties DBMS_AQ.message_properties_t;
  message_handle RAW(16);
  MESSAGE SYS.AQ$_JMS_TEXT_MESSAGE;
BEGIN
  DBMS_AQ.DEQUEUE( queue_name => 'RMSPRD.AQ$_NB_JMS_COSTCHG_TEXT_E', dequeue_options => dequeue_options, message_properties => message_properties, payload => MESSAGE, msgid => message_handle);
  DBMS_AQ.ENQUEUE( queue_name => 'RMSPRD.NB_JMS_COSTCHG_QUEUE', enqueue_options => enqueue_options, message_properties => message_properties, payload => MESSAGE, msgid => message_handle);
END;
/

commit;
/