Oracle | DBMS

Oracle DBMS_TEQK Version 26ai

General Information

Library Note

Morgan's Library Page Header

The best Oracle News for FY2026

Oracle Database 26ai is now availble. If you haven't you downloaded already: Why?

Purpose Undocumented Advanced Queuing related internal package. About the only thing we can find that might give a hint to its purpose is the following:

SQL> desc dba_queue_partition_assignment_table ERROR: ORA-04043: object dba_queue_partition_assignment_table does not exist SQL> desc dba_queue_partition_assignment_table ERROR: ORA-04043: object dba_queue_partition_assignment_table does not exist SQL> desc all_queue_partition_assignment_table ERROR: ORA-04043: object all_queue_partition_assignment_table does not exist SQL> desc user_queue_partition_assignment_table Name Null? Type ------------------ -------- -------------------------- OWNER NOT NULL VARCHAR2(128) QUEUE_ID NOT NULL NUMBER QUEUE_NAME NOT NULL VARCHAR2(128) SUBSCRIBER_ID NOT NULL NUMBER SUBSCRIBER_NAME NOT NULL VARCHAR2(128) SESSION_ID NOT NULL NUMBER GROUP_LEADER NOT NULL NUMBER PARTITION_ID NUMBER VERSION# NUMBER INST_ID NOT NULL NUMBER FLAGS NUMBER CLIENT_ID VARCHAR2(128) CLIENT_VERSION VARCHAR2(128) AUDIT_SID NUMBER CREATE_TIME TIMESTAMP(6) WITH TIME ZONE

and the most interesting thing about it is that there isn't a CDB, DBA, or ALL version of the view.

AUTHID CURRENT_USER

Data Types TYPE partition_list ....

Dependencies

AQ$_QPAT_INFO	DBMS_RESOURCE_MANAGER
AQ$_QPAT_INFO_LIST	DBMS_RESOURCE_MANAGER_PRIVS
AQ$_QPIM_INFO	DBMS_SYSTEM
AQ$_QPIM_INFO_LIST	DBMS_SYS_ERROR
DBMS_AQADM	DBMS_UTILITY
DBMS_AQADM_INV	DUAL
DBMS_AQADM_SYS	GV_$LISTENER_NETWORK
DBMS_AQADM_SYSCALLS	PLITBLM
DBMS_AQ_LIB	USER_QUEUE_PARTITION_ASSIGNMENT_TABLE
DBMS_LOCK	USER_QUEUE_SHARDS
DBMS_PRVTSQIS

Documented No

First Available 20c

Security Model Owned by SYS with EXECUTE granted to PUBLIC

Source {ORACLE_HOME}/rdbms/admin/dbmsteqk.plb

Subprograms

AQ$_ALTER_KAFKA_TOPIC	AQ$_DELETE_POLL_INTERVAL	AQ$_JOIN_GROUP
AQ$_CONNECT_ME	AQ$_DROP_KAFKA_TOPIC	AQ$_SET_POLL_INTERVAL
AQ$_CREATE_KAFKA_TOPIC	AQ$_GRANT_PRIV_FOR_REPL	AQ$_SYNC

AQ$_ALTER_KAFKA_TOPIC (new 23ai)

Undocumented dbms_teqk.aq$_alter_kafka_topic(topicname IN VARCHAR2);

TBD

AQ$_CONNECT_ME

Undocumented dbms_teqk.aq$_connect_me( schema IN VARCHAR2, queue_name IN VARCHAR2, subscriber_name IN VARCHAR2, inst_id OUT NUMBER, url OUT NUMBER, flags IN OUT NUMBER, p_list OUT sys.dbms_teqk.partition_list);

TBD

AQ$_CREATE_KAFKA_TOPIC (new 23ai)

Undocumented dbms_teqk.aq$_create_kafka_topic( topicname IN VARCHAR2, partition_num IN NUMBER, retntniontime IN NUMBER, partition_assignment_mode IN NUMBER, replication_mode IN BINARY_INTEGER);

TBD

AQ$_DELETE_POLL_INTERVAL (new 23ai)

Undocumented dbms_teqk.aq$_delete_poll_interval( schema_name IN VARCHAR2, queue_name IN VARCHAR2, subscriber_name IN VARCHAR2);

TBD

AQ$_DROP_KAFKA_TOPIC (new 23ai)

Undocumented dbms_teqk.aq$_drop_kafka_topic(topicname IN VARCHAR2);

TBD

AQ$_GRANT_PRIV_FOR_REPL (new 23ai)

Undocumented dbms_teqk.aq$_grant_priv_for_repl(uname IN VARCHAR2);

TBD

AQ$_JOIN_GROUP

Undocumented dbms_teqk.aq$_join_group( qpat_list IN OUT sys.aq$_qpat_info_list, qpim_list OUT sys.aq$_qpat_info_list, shard_num OUT NUMBER, version# OUT NUMBER);

TBD

AQ$_SET_POLL_INTERVAL (new 23ai)

Undocumented dbms_teqk.aq$creat_kafka_topic( schema_name IN VARCHAR2, queue_name IN VARCHAR2, subscriber_name IN VARCHAR2, idle_time IN NUMBER);

TBD

AQ$_SYNC

Undocumented dbms_teqk.aq$_sync( qpat_list IN OUT sys.aq$_qpat_info_list, version# IN OUT NUMBER);

TBD