Oracle DBMS_AQADM_SYS
Version 21c

General Information
Library Note Morgan's Library Page Header
Which has the higher priority in your organization: Deploying a new database or securing the ones you already have? Looking for a website, and resources, dedicated solely to securing Oracle databases? Check out DBSecWorx.
Purpose Advanced Queuing support used by GoldenGate, LDAP, Logical Standby, and for kernel support.
AUTHID DEFINER
Constants

The list at right is likely incomplete but were found during discovery.
Name Data Type Value
 General
DISABLE_AQ_DDL BINARY_INTEGER 0
ENABLE_AQ_DDL BINARY_INTEGER 1
NOTIFICATION_SUBSCRIBER BINARY_INTEGER 16
PUBLIC_SUBSCRIBER BINARY_INTEGER 32
Dependencies
ALL_OBJECTS DBMS_AQ DBMS_STREAMS_ADM_IVK
AQ$_AGENT DBMS_AQADM DBMS_STREAMS_ADM_UTL
AQ$_DEQUEUE_LOG_PARTITION_MAP DBMS_AQADM_INV DBMS_STREAMS_ADM_UTL_INVOK
AQ$_INTERNET_AGENTS DBMS_AQADM_LIB DBMS_STREAMS_DATAPUMP_UTIL
AQ$_INTERNET_AGENT_PRIVS DBMS_AQADM_SYSCALLS DBMS_SYSTEM
AQ$_MESSAGE_TYPES DBMS_AQADM_VAR DBMS_SYS_ERROR
AQ$_NONDURSUB_SEQUENCE DBMS_AQIN DBMS_SYS_SQL
AQ$_PROPAGATION_STATUS DBMS_AQINT_LIB DBMS_TRANSACTION
AQ$_QUEUES DBMS_AQJMS DBMS_TRANSFORM_EXIMP
AQ$_QUEUE_PARAMS DBMS_AQJMS_INTERNAL DBMS_UTILITY
AQ$_QUEUE_PARTITION_MAP DBMS_AQ_IMPORT_INTERNAL DUAL
AQ$_QUEUE_SHARDS DBMS_AQ_IMPORT_INTERNAL_DR EXPACT$
AQ$_QUEUE_TABLES DBMS_AQ_INV EXPDEPACT$
AQ$_QUEUE_TABLE_AFFINITIES DBMS_AQ_LDAP_LIB EXPDEPOBJ$
AQ$_RECIPIENTS DBMS_AQ_LIB GLOBAL_CONTEXT
AQ$_REG_INFO_LIST DBMS_AQ_SYS_EXP_ACTIONS KUPC$QUE_INT
AQ$_REPLAY_INFO DBMS_AQ_SYS_EXP_INTERNAL KUPW$WORKER
AQ$_SCHEDULES DBMS_AQ_SYS_IMP_INTERNAL MGWI_ADMIN
AQ$_SIG_PROP DBMS_ASSERT OBJ$
AQ$_SRVNTFN_MESSAGE DBMS_ISCHED PLITBLM
AQ$_SUBSCRIBERS DBMS_LOGREP_UTIL PROPS$
AQ$_SUBSCRIBER_TABLE DBMS_LOGSTDBY SCHEDULER$_DBMSJOB_MAP
COL$ DBMS_OUTPUT STREAMS$_APPLY_PROCESS
COLTYPE$ DBMS_PRIV_CAPTURE STREAMS$_CAPTURE_PROCESS
COLTYPE$
DBA_DEPENDENCIES
DBMS_PROPAGATION_INTERNAL STREAMS$_MESSAGE_CONSUMERS
DBA_JOBS DBMS_PRVTAQIM STREAMS$_PROPAGATION_PROCESS
DBA_OBJECTS DBMS_PRVTAQIP TABPART$
DBA_QUEUES DBMS_PRVTAQIS TRANSFORMATIONS$
DBA_QUEUE_TABLES DBMS_PRVTSQDS TS$
DBA_TABLES DBMS_PRVTSQIS USER$
DBA_TABLESPACES DBMS_RULEADM_INTERNAL UTL_HTTP
DBA_TAB_COLUMNS DBMS_RULE_ADM V$INSTANCE
DBA_TAB_PRIVS DBMS_SCHEDULER X$KSPPCV
DBA_USERS DBMS_SQL X$KSPPI
DBMS_APPLY_ADM DBMS_STATS_INTERNAL  
Documented No
First Available Not known
Security Model Owned by SYS with no privileges granted
Source {ORACLE_HOME}/rdbms/admin/dbmsaqds.plb
{ORACLE_HOME}/rdbms/admin/prvtaqds.plb
Subprograms
ADD_ALIAS_TO_LDAP DEL_ALIAS_FROM_LDAP MIGRATE_QUEUE_TABLE_INT
ADD_BUFFER DEL_CONNECTION_FROM_LDAP MOD_QUEUE_IN_LDAP
ADD_BUFFER_INT DEL_QUEUE_FROM_LDAP MOD_QUEUE_TAB_IN_LDAP
ADD_BUFFER_TABLES DEL_SUBSCRIBER_FROM_LDAP MOD_SUBSCRIBER_IN_LDAP
ADD_BUFFER_TABLES_INT DESTROYCACHEOBJECT NEWQ_10_1
ADD_CHILD DISABLE_DB_ACCESS NEWQ_12G
ADD_CONNECTION_TO_LDAP DISABLE_PROP_SCHEDULE_INT NEWQ_8_1
ADD_DB_LINK DISABLE_REGISTRATION OBJECT_EXISTS
ADD_NONDURABLE_SUBSCRIBER DROP_AQ_AGENT PATCH_DEQUEUE_IOT
ADD_QTAB_EXPDEP DROP_BUFFER PATCH_HISTORY_IOT
ADD_QUEUE_TAB_TO_LDAP DROP_BUFFER_VIEW PATCH_QUEUE_TABLE-2
ADD_QUEUE_TO_LDAP DROP_EVICTION_TABLE PATCH_TIMEMGR_IOT
ADD_SPILLED_IOT DROP_QTAB_EXPDEP PRS_CMT
ADD_SPILLED_TABLE DROP_QUEUE PRS_QTYP
ADD_SUBSCRIBER DROP_QUEUE_INT PRS_RBK
ADD_SUBSCRIBER_11G DROP_QUEUE_TABLE PRS_SEQ
ADD_SUBSCRIBER_TO_LDAP DROP_QUEUE_TABLE_INT PSTUPD_CREATE_EVICTION_TABLE
ALTER_AQ_AGENT DROP_QUEUE_TAB_FROM_LDAP PURGE_QUEUE_TABLE
ALTER_PROPAGATION_SCHEDULE_INT DROP_SHARDED_QUEUE PURGE_QUEUE_TABLE_ALL
ALTER_QUEUE DROP_SHARDED_QUEUE_INT PURGE_QUEUE_TABLE_INT
ALTER_QUEUE_INT DROP_SPILLED_IOT QT_BUFQ_COUNT
ALTER_QUEUE_TABLE DROP_SPILLED_TABLE QT_COMPAT
ALTER_QUEUE_TABLE_INT DUMP_TRACE QUEUE_SUBSCRIBERS
ALTER_SHARDED_QUEUE ENABLE_DB_ACCESS RECOVER_PROPAGATION_INT
ALTER_SUBSCRIBER ENABLE_JMS_TYPES REGISTER_DRIVER
ALTER_SUBSCRIBER_11G ENABLE_JMS_TYPES_INT REMOVE_ALL_NONDURABLESUB
ALTER_SUBSCRIBER_11G_INT ENABLE_PROP_SCHEDULE_INT REMOVE_CHILD_SUB
ANALYZE_MESSAGE_CACHE ENABLE_REGISTRATION REMOVE_DB_LINK
AQ$_PROPAGATION_PROCEDURE ENDTRANS REMOVE_NONDURABLESUB_CLIENT
AQ$_PROPAQ ENQUOTE_LITERAL REMOVE_NONDURABLE_DBSESSION
BEGINTRANS FAILOVER_NOTIF_QUEUE REMOVE_ORPHMSGS
BFQ GET_ADT_QTABLE_PAYLOAD_NAME REMOVE_ORPHMSGS_INT
CALCULATE_MESSAGE_CACHE GET_CLIENT_SESSION_ID REMOVE_ORPHMSGS_NR
CHANGE_QUEUE_REPL_MODE GET_OWNER_INSTANCE REMOVE_SUBSCRIBER
CHK_QT_FLG GET_PROCNAME REMOVE_SUBSCRIBER_11G
CLR_QT_FLG GET_PROP_SEQNO REMOVE_SUBSCRIBER_11G_INT
CNF GET_QUEUE_PARAMETER REVOKE_QUEUE_PRIVILEGE
COMPATIBLE_100 GET_QUEUE_TABLE_NAME REVOKE_QUEUE_PRIVILEGE_INT
COMPUTE_NAME GET_REMOTE_QTYPE_INFO_TTC REVOKE_SYSTEM_PRIVILEGE
CREATECACHEOBJECT GET_SCHEMA_OID RULESET_EXISTS
CREATEQUEUE GET_SEQ_NXTVAL SCHEDULE_PROPAGATION
CREATE_AQ_AGENT GET_TRANS_INFO SCHEDULE_PROPAGATION_INT
CREATE_BASE_VIEW GET_TYPE_INFO SCQ_8_0
CREATE_BASE_VIEW10_1_0 GRANT_QUEUE_PRIVILEGE SCQ_8_1
CREATE_BUFFER_VIEW GRANT_QUEUE_PRIVILEGE_INT SECURE_QT
CREATE_BUFFER_VIEW101 GRANT_SYSTEM_PRIVILEGE SETREGISTRATIONNAME
CREATE_DEQ_VIEW GRANT_TYPE_ACCESS SETSTREAMSCAPTUREOFF
CREATE_DEQ_VIEW_PRE11_2 IMPPEND_FLAG_CLEAR SET_QUEUE_PARAMETER
CREATE_EVICTION_TABLE INVALIDATE_QUEUE START_QUEUE
CREATE_EXCEPTION_MAP_12G IN_DATAPUMP_IMPORT START_QUEUE_INT
CREATE_EXCEPTION_QUEUE IS12GJMSQUEUE STOP_MESSAGE_FORWARDING
CREATE_NP_QUEUE IS12GSHARDEDQUEUE STOP_QUEUE
CREATE_NP_QUEUE_INT ISALIVE STOP_QUEUE_INT
CREATE_PLSQL_NOTIF_QUEUE ISSHARDEDQUEUE TGQ
CREATE_PLSQL_NOTIF_QUEUE_INT I_BIND_AGENT TRANSFORMATION_EXISTS
CREATE_PROP_VIEWS I_CREATE_QT UNSCHEDULE_PROPAGATION
CREATE_QT_DICTIONARY I_UNBIND_AGENT UNSCHEDULE_PROPAGATION_INT
CREATE_QUEUE KWQAQPDHASLOB UNSET_QUEUE_PARAMETER
CREATE_QUEUE_INT LOCKQUEUE UPGRADE_SHARDED_QUEUE
CREATE_QUEUE_TABLE MARK_INTERNAL_TABLES VALIDATE_QTAB_QUEUES
CREATE_QUEUE_TABLE_INT MATCH_TDS VALIDATE_QUEUE
CREATE_QUEUE_TABLE_TZ MCQ VERIFY_AQ_TIMEZONE
CREATE_SHARDED_QUEUE MCQ_12G VERIFY_QUEUE_TYPES
CREATE_SPILLED_TABLES_IOTS MCQ_12GJMS VERIFY_SHARDED_QUEUE
CTQT MCQ_8_0 WRAPPER_CREATE_DEQUEUE_LOG
DELETE_FROM_DEQIOT MCQ_8_1 WRITE_TRACE
DELETE_MESSAGES_FOR_REMOVESUB MIGRATE_QUEUE_TABLE  
 
ADD_ALIAS_TO_LDAP
Undocumented dbms_aqadm_sys.add_alias_to_ldap(
alias        IN VARCHAR2,
obj_location IN VARCHAR2);
TBD
 
ADD_CONNECTION_TO_LDAP
Undocumented

Overload 1
dbms_aqadm_sys.add_connection_to_ldap(
connection IN VARCHAR2,
host       IN VARCHAR2,
port       IN BINARY_INTEGER,
sid        IN VARCHAR2,
driver     IN VARCHAR2,
type       IN BINARY_INTEGER);
TBD
Overload 2 dbms_aqadm_sys.add_connection_to_ldap(
connection  IN VARCHAR2,
jdbc_string IN VARCHAR2,
username    IN VARCHAR2,
password    IN VARCHAR2,
type        IN BINARY_INTEGER);
TBD
 
ADD_QUEUE_TAB_TO_LDAP
Undocumented dbms_aqadm_sys.add_queue_tab_to_ldap (
queue_tab_schema   IN VARCHAR2,
queue_table        IN VARCHAR2,
payload_type       IN VARCHAR2,
multiple_consumers IN BOOLEAN,
message_grouping   IN BINARY_INTEGER,
primary_instance   IN BINARY_INTEGER,
secondary_instance IN BINARY_INTEGER,
compatibility      IN VARCHAR2,
comment            IN VARCHAR2);
TBD
 
ADD_QUEUE_TO_LDAP
Undocumented dbms_aqadm_sys.add_queue_to_ldap(
queue_schema   IN VARCHAR2,
queue_name     IN VARCHAR2,
qt_schema      IN VARCHAR2,
queue_table    IN VARCHAR2,
queue_type     IN BINARY_INTEGER,
max_retries    IN BINARY_INTEGER,
retry_delay    IN BINARY_INTEGER,
retention_time IN BINARY_INTEGER);
TBD
 
ADD_SUBSCRIBER
Undocumented

Demo from exechae.sql
dbms_aqadm_sys.add_subscriber(
queue_name          IN VARCHAR2,
subscriber          IN sys.aq$_agent,
rule                IN VARCHAR2,
security_check      IN BOOLEAN,
in_recursive_txn    IN BOOLEAN,
add_jms_entry       IN BOOLEAN,
transformation      IN VARCHAR2,
ruleset             IN VARCHAR2,
negative_ruleset    IN VARCHAR2,
properties          IN NUMBER,
name_canonicalized  IN BOOLEAN,
queue_to_queue      IN BOOLEAN,
client_session_guid IN VARCHAR2,
instno              IN NUMBER,
current_user        IN VARCHAR2);
-- Rem Define the HAE_SUB subscriber for the alert_que

DECLARE
  subscriber sys.aq$_agent;
BEGIN
  subscriber := sys.aq$_agent('HAE_SUB', NULL, NULL);

  dbms_aqadm_sys.add_subscriber(queue_name => 'SYS.ALERT_QUE',
                                subscriber => subscriber,
                                rule => 'tab.user_data.MESSAGE_LEVEL <> '
                                        || sys.dbms_server_alert.level_clear ||
                                        ' AND tab.user_data.MESSAGE_GROUP = ' ||
                                        '''High Availability''',
                                        transformation => 'SYS.haen_txfm_obj',
  properties => dbms_aqadm_sys.NOTIFICATION_SUBSCRIBER+dbms_aqadm_sys.PUBLIC_SUBSCRIBER);
EXCEPTION
  WHEN OTHERS THEN
    IF sqlcode = -24034 THEN
      NULL
    ELSE
      RAISE;
    END IF;
END;
/
 
ADD_SUBSCRIBER_TO_LDAP
Undocumented dbms_aqadm_sys.add_queue_subscriber_to_ldap(
queue_schema   IN VARCHAR2,
queue_name     IN VARCHAR2,
subscriber     IN sys.sq$agent,
add_jms_entry  IN BOOLEAN,
rule           IN VARCHAR2,
transformation IN VARCHAR2);
TBD
 
CREATE_AQ_AGENT
Undocumented

Demo from catscqa.sql
dbms_aqadm_sys.create_aq_agentr(
agent_name           IN VARCHAR2,
certificate_location IN VARCHAR2 DEFAULT NULL,
enable_http          IN BOOLEAN  DEFAULT NULL,
enable_smtp          IN BOOLEAN  DEFAULT NULL,
enable_anyp          IN BOOLEAN  DEFAULT NULL,
name_canonicalized   IN BOOLEAN);
BEGIN
  dbms_aqadm_sys.create_aq_agent(agent_name => 'SCHEDULER$_EVENT_AGENT',
                                 name_canonicalized => FALSE);
EXCEPTION
  WHEN OTHERS THEN
    IF sqlcode = -24089 THEN
      NULL;
    ELSE
      RAISE;
    END IF;
END;
/
 
CREATE_BASE_VIEW
Undocumented

Demo from xrdud121.sql

Note that this code was will compile in 12.1 but will no longer compile as ksdwrt is no longer in the dbms_system package.
dbms_aqadm_sys.create_base_view(
qt_schema IN VARCHAR2,
qt_name   IN VARCHAR2,
qt_flags  IN NUMBER);
DECLARE
 altvstmt VARCHAR2(1000);
BEGIN
  FOR cur_rec IN (SELECT distinct t.schema, t.name, t.flags
                  FROM system.aq$_queue_tables t, system.aq$_queues q
                  WHERE t.objno = q.table_objno and NVL(q.sharded,0) =0) LOOP
    BEGIN
      BEGIN
        altvstmt := 'alter view '||dbms_assert.enquote_name(cur_rec.schema,FALSE) ||'.'||
               dbms_assert.enquote_name('AQ$_'||cur_rec.name ||'_F',FALSE) || ' compile';
        EXECUTE IMMEDIATE altvstmt;
      EXCEPTION WHEN OTHERS THEN
        NULL;
      END;

      IF cur_rec.name != 'AQ$DEF$_AQCALL' AND cur_rec.name != 'DEF$_AQERROR' THEN
        IF bitand(cur_rec.flags, 1) = 1 THEN -- multi-consumer queue
          sys.dbms_prvtaqim.create_base_view(cur_rec.schema,cur_rec.name,cur_rec.flags);
        ELSE   -- singleconsumer queue
          sys.dbms_aqadm_sys.create_base_view(cur_rec.schema,cur_rec.name,cur_rec.flags);
        END IF;
      END IF;
    END;
  END LOOP;
EXCEPTION WHEN OTHERS THEN
  dbms_system.ksdwrt(dbms_system.trace_file,'error in unsharded view creation'||sqlcode);
  RAISE;
END;
/
 
CREATE_BUFFER_VIEW
Undocumented

Demo from f1102000.sql
dbms_aqadm_sys.create_buffer_view(
qt_schema IN VARCHAR2,
qt_name   IN VARCHAR2,
ig_err    IN BOOLEAN);
See NEWQ_10_1 demo below.
 
CREATE_SPILLED_TABLES_IOTS
Undocumented

Demo from execaq.sql
dbms_aqadm_sys.create_spilled_tables_iots;
-- create aq$_<QT>_P and aq$_<QT>_D for buffered queue tables
BEGIN
  dbms_aqadm_sys.create_spilled_tables_iots;
END;
/
 
DEL_ALIAS_FROM_LDAP
Undocumented dbms_aqadm_sys.del_alias_from_ldap(alias IN VARCHAR2);
exec dbms_aqadm_sys.del_alias_from_ldap('LDAPALIAS');

PL/SQL procedure successfully completed.
 
DEL_CONNECTION_FROM_LDAP
Undocumented dbms_aqadm_sys.del_connection_from_ldap(connection IN VARCHAR2);
TBD
 
DEL_QUEUE_FROM_LDAP
Undocumented dbms_aqadm_sys.del_queue_from_ldap(
queue_schema IN VARCHAR2,
queue_name   IN VARCHAR2);
TBD
 
DEL_SUBSCRIBER_FROM_LDAP
Undocumented dbms_aqadm_sys.del_subscriber_from_ldap(
queue_schema  IN VARCHAR2,
queue_name    IN VARCHAR2,
subscriber    IN sys.aq$_agent,
del_jms_entry IN BOOLEAN);
TBD
 
DDROP_BUFFER_VIEW
Undocumented

Demo from f1102000.sql
dbms_aqadm_sys.drop_buffer_view(
qt_schema IN VARCHAR2,
qt_name   IN VARCHAR2);
See NEWQ_10_1 demo below.
 
DROP_QUEUE_TAB_FROM_LDAP
Undocumented dbms_aqadm_sys.drop_queue_tab_from_ldap(
queue_tab_schema IN VARCHAR2,
queue_table      IN VARCHAR2);
TBD
 
ENABLE_DB_ACCESS
Undocumented dbms_aqadm_sys.enable_db_access(
agent_name          IN VARCHAR2,
db_username         IN VARCHAR2,
names_canonicalized IN BOOLEAN);
TBD
 
GRANT_SYSTEM_PRIVILEGE
Undocumented dbms_aqadm_sys.grant_system_privilege(
privilege    IN VARCHAR2,
grantee      IN VARCHAR2,
admin_option IN BOOLEAN,
grantor      IN VARCHAR2);
TBD
 
MARK_INTERNAL_TABLES
Undocumented

Example from a18.sql
dbms_aqadm_sys.mark_internal_tables(set_indicator_flag IN BINARY_INTEGER);
exec sys.dbms_aqadm_sys.mark_internal_tables(dbms_aqadm_sys.enable_aq_ddl);
 
MCQ_12GJMS
Undocumented

Demo from f1202000
dbms_aqadm_sys.mcq_12gJMS(qt_flags IN NUMBER) RETURN BOOLEAN;
BEGIN
  FOR cur_rec IN (SELECT t.schema, t.name, t.flags, q.eventid
                  FROM system.aq$_queue_tables t, system.aq$_queues q
                  WHERE t.objno = q.table_objno
                  AND q.sharded =1) LOOP
    BEGIN
      sys.dbms_prvtaqim.create_base_view_12C_12201(cur_rec.schema, cur_rec.name,
        cur_rec.eventid, sys.dbms_aqadm_sys.mcq_12gJms(cur_rec.flags), cur_rec.flags);
    END;
  END LOOP;
EXCEPTION
  WHEN OTHERS THEN
    dbms_system..ksdwrt(dbms_system.trace_file, 'error in 12C view creation' || sqlcode);
    RAISE;
END;
/
 
MCQ_8_1
Undocumented

Example from a1102000.sql
dbms_aqadm_sys.mcq_8_1(qt_flags IN NUMBER) RETURN BOOLEAN;
DECLARE
 CURSOR qt_cur IS
 SELECT qt.schema, qt.name, qt.flags
 FROM system.aq$_queue_tables qt;
BEGIN
  FOR qt_rec IN qt_cur LOOP
    BEGIN
      IF dbms_aqadm_sys.mcq_8_1(qt_rec.flags) THEN
        sys.dbms_prvtaqim.create_deq_view(qt_rec.schema, qt_rec.name, qt_rec.flags);
      END IF;
EXCEPTION
  WHEN OTHERS THEN
      dbms_system.ksdwrt(dbms_system.alert_file, 'a1102000.sql: recreate
      deq view ' || 'failed for ' || qt_rec.schema || '.' || qt_rec.name);
    END;
  END LOOP;
END;
/
 
MOD_QUEUE_IN_LDAP
Undocumented dbms_aqadm_sys.mod_queue_in_ldap(
queue_schema   IN VARCHAR2,
queue_name     IN VARCHAR2,
max_retries    IN BINARY_INTEGER,
retry_delay    IN BINARY_INTEGER,
retention_time IN BINARY_INTEGER);
TBD
 
MOD_QUEUE_TAB_IN_LDAP
Undocumented dbms_aqadm_sys.mod_queue_tab_in_ldap(
queue_tab_schema   IN VARCHAR2,
queue_table        IN VARCHAR2,
primary_instance   IN BINARY_INTEGER,
secondary_instance IN BINARY_INTEGER,
comment            IN VARCHAR2);
TBD
 
MOD_SUBSCRIBER_IN_LDAP
Undocumented dbms_aqadm_sys.mod_subscriber_in_ldap(
queue_schema   IN VARCHAR2,
queue_name     IN VARCHAR2,
subscriber     IN sys.aq$agent,
rule           IN VARCHAR2,
transformation IN VARCHAR2);
TBD
 
NEWQ_10_1
Undocumented

Demo from f1102000.sql
dbms_aqadm_sys.newq_10_1(
DECLARE
 cursor qt_cur is select schema, name, flags from system.aq$_queue_tables;
BEGIN
  FOR qt IN qt_cur LOOP
    IF (sys.dbms_aqadm_sys.mcq_8_1(qt.flags) AND
      sys.dbms_aqadm_sys.newq_10_1(qt.flags)) THEN
      BEGIN
        --sys.dbms_prvtaqim.drop_dqlog_view(qt.schema, qt.name);

        /* bug15964874/16105750: Recreate buffer view for WM$EVENT_QUEUE_TABLE */
        IF (qt.name='WM$EVENT_QUEUE_TABLE') THEN
            sys.dbms_aqadm_sys.drop_buffer_view(qt.schema, qt.name);
            sys.dbms_aqadm_sys.create_buffer_view(qt.schema, qt.name, TRUE);
        END IF;
        sys.dbms_prvtaqim.create_base_view11_2_0(qt.schema, qt.name, qt.flags);
      EXCEPTION
        WHEN OTHERS THEN
          dbms_system.ksdwrt(dbms_system.alert_file, 'f1102000.sql: create _L view or
               recreate base' || ' view failed for ' || qt.schema || '.' || qt.name);
       END;
    END IF;
  END LOOP;
END;
/
 
REGISTER_DRIVER
Undocumented

Demo from catexp.sql
dbms_aqadm_sys.register_driver;
exec dbms_aqadm_sys.register_driver();

Related Topics
Built-in Functions
Built-in Packages
Database Security
Advanced Queuing Demo 1
Advanced Queuing RAC Demo
DBMS_AQ
DBMS_AQADM_INV
DBMS_AQADM_SYSCALLS
DBMS_AQADM_VAR
DBMS_AQIN
DBMS_JOB
DBMS_PRVTAQIP
What's New In 19c
What's New In 20c-21c

Morgan's Library Page Footer
This site is maintained by Dan Morgan. Last Updated: This site is protected by copyright and trademark laws under U.S. and International law. © 1998-2021 Daniel A. Morgan All Rights Reserved
  DBSecWorx