CREATE or replace TYPE message_typ AS object(
       sender_id              NUMBER,
       subject                VARCHAR2(30),
       text                   VARCHAR2(1000));
    /


    BEGIN
       DBMS_AQADM.CREATE_QUEUE_TABLE(
          queue_table            => 'obj_qtab',
          queue_payload_type     => 'message_typ',
          multiple_consumers     => true
          );
    END;
    /

begin
  DBMS_AQADM.create_queue (queue_name => 'obj_qtab_ex', queue_table => 'obj_qtab',
      queue_type => DBMS_AQADM.exception_queue, COMMENT => 'My Exception AQ');
  DBMS_AQADM.START_QUEUE (queue_name=> 'obj_qtab_ex',enqueue => FALSE, dequeue => TRUE);    
end;


    BEGIN
       DBMS_AQADM.CREATE_QUEUE(
          queue_name         =>  'obj_queue',
          queue_table        =>  'obj_qtab');
    END;
    /

    BEGIN
       DBMS_AQADM.START_QUEUE (
          queue_name         => 'obj_queue');
    END;
    /

create or replace procedure queue_test
  (
    context  raw
   ,reginfo  sys.aq$_reg_info
   ,descr    sys.aq$_descriptor
   ,payload  raw
   ,payloadl number
  ) as
    dequeue_options    dbms_aq.dequeue_options_t;
    message_properties dbms_aq.message_properties_t;
    message_handle     raw(16);
    message            message_typ;
  begin
    null; 
    --
  end;
end queue_test;
/

begin
  --создаем подписчика
  dbms_aqadm.add_subscriber('obj_qtab_ex', sys.aq$_agent('subscriber_queue_test', null, null));
  --регистрируем подписчика
  dbms_aq.register(sys.aq$_reg_info_list(sys.aq$_reg_info('obj_qtab_ex:subscriber_queue_test', dbms_aq.namespace_aq, 'plsql://queue_test', hextoraw('FF'))), 1);
  commit;
end;