DECLARE
po dbms_aqadm.aq$_purge_options_t;
BEGIN
   po.block := FALSE;
   DBMS_AQADM.PURGE_QUEUE_TABLE(
     queue_table     => 'tcn_gxc_in_queue_table',
     purge_condition => NULL,
     purge_options   => po);
END;
/

DECLARE
po dbms_aqadm.aq$_purge_options_t;
BEGIN
   po.block := FALSE;
   DBMS_AQADM.PURGE_QUEUE_TABLE(
     queue_table     => 'tcn_gxc_out_queue_table',
     purge_condition => NULL,
     purge_options   => po);
END;
/

DECLARE
 CURSOR notification_cursor IS
  SELECT p.id        notification_id,
         p.status_id notification_status_id
    FROM tcn_sys_notifications p,
         tcn_sys_notification_statuses s
   WHERE p.status_id = s.id
     AND (s.status = 'ontvangen'
      OR s.status = 'ontvangen zonder geometrie');

BEGIN
   FOR notification IN notification_cursor
   LOOP
    tcn_ctl_notification.geoxchange_enqueue(notification.notification_id,
                                            notification.notification_status_id,
                                            NULL,
                                            NULL);
   END LOOP;
END;
/

DECLARE
 CURSOR notification_cursor IS
  SELECT p.id        notification_id,
         p.status_id notification_status_id
    FROM tcn_sys_notifications p,
         tcn_sys_notification_statuses s
   WHERE p.status_id = s.id
     AND s.status = 'ingecheckt';

BEGIN
   FOR notification IN notification_cursor
   LOOP
    tcn_ctl_notification.geoxchange_enqueue(notification.notification_id,
                                            notification.notification_status_id,
                                            NULL,
                                            NULL);
   END LOOP;
END;
/