--создаем таблицу для очереди
BEGIN
  DBMS_AQADM.CREATE_QUEUE_TABLE(
     queue_table         => 'AQ_TAB',
     queue_payload_type  => 'MSG_TYPE');
END;
/
--создаем саму очередь
BEGIN
   DBMS_AQADM.CREATE_QUEUE(
      queue_name         =>  'QUEUE1',
      queue_table        =>  'AQ_TAB');
END;
/

--включаем очередь
BEGIN
   DBMS_AQADM.START_QUEUE(
      queue_name        => 'QUEUE1');
END;

--процедура добавлящая сообщение в очередь
declare
procedure enqueue_msg (p_msg in varchar2)
as
   enqueue_options DBMS_AQ.enqueue_options_t;
   msg_properties  DBMS_AQ.message_properties_t;
   msg_handle      RAW(16);
   msg             msg_type;
BEGIN
   msg := msg_type('Subject', p_msg);
   DBMS_AQ.ENQUEUE(
      queue_name              => 'QUEUE1',
      enqueue_options         => enqueue_options,
      message_properties      => msg_properties,
      payload                 => msg,
      msgid                   => msg_handle);
   COMMIT;
END;
begin
  for r in(select table_name from dba_tables where rownum<=10) 
  loop
    enqueue_msg(r.table_name);
    dbms_lock.sleep(3);
  end loop;
end;
/

DECLARE
  dequeue_options      DBMS_AQ.dequeue_options_t;
  message_properties   DBMS_AQ.message_properties_t;
  message_handle       RAW (16);
  msg                  msg_type;
  no_messages exception;
  msg_content          VARCHAR2 (4000);
  PRAGMA EXCEPTION_INIT (no_messages, -25228);
BEGIN
  dequeue_options.wait := DBMS_AQ.NO_WAIT;    
LOOP
  DBMS_AQ.DEQUEUE (queue_name           => 'QUEUE1',
                      dequeue_options      => dequeue_options,
                      message_properties   => message_properties,
                      payload              => msg,
                      msgid                => message_handle
                     );
  DBMS_OUTPUT.PUT_LINE( msg.text);
END LOOP;
  EXCEPTION
  WHEN no_messages
  THEN
     DBMS_OUTPUT.PUT_LINE ('No more messages left');
END;

--Создаем тип сообщения
CREATE TYPE msg_type AS object(
   subj varchar2(100),
   text varchar2(500));
/