ACE Director Alum Daniel Morgan, founder of Morgan's Library, is scheduling
complimentary technical Workshops on Database Security for the first 30
Oracle Database customers located anywhere in North America, EMEA, LATAM, or
APAC that send an email to
asra_us@oracle.com. Request a Workshop for
your organization today.
Purpose
Advanced Queuing Administrative APIs.
AUTHID
DEFINER
Dependencies
AQ$_AGENT
DBMS_AQADM_VAR
DBMS_PRVTAQIP
AQ$_QUEUES
DBMS_AQINT_LIB
DBMS_PRVTAQIS
AQ$_QUEUE_TABLES
DBMS_AQJMS
DBMS_PRVTSQDS
DBMS_AQ
DBMS_AQ_IMPORT_INTERNAL_DR
DBMS_PRVTSQIS
DBMS_AQADM
DBMS_AQ_SYS_EXP_INTERNAL
DBMS_RULEADM_INTERNAL
DBMS_AQADM_INV
DBMS_AQ_SYS_IMP_INTERNAL
DBMS_RULE_ADM
DBMS_AQADM_LIB
DBMS_ASSERT
DBMS_STREAMS_CONTROL_ADM
DBMS_AQADM_SYS
DBMS_PRVTAQIM
DBMS_SYS_ERROR
Documented
No
Exceptions
Error Code
Reason
First Available
Not known
Security Model
Owned by SYS with no privileges granted
All package functionality is protected by an ACCESSIBLE BY Clause
All package functionality is protected by an ACCESSIBLE BY Clause
dbms_aqadm_syscalls.get_max_streams_pool(value OUT NUMBER);
DECLARE
n NUMBER;
BEGIN
dbms_aqadm_syscalls.get_max_streams_pool(n);
dbms_output.put_line(n);
END;
/
dbms_aqadm_syscalls.get_max_streams_pool(n);
*
ERROR at line 4:
ORA-06550: line 4, column 3:
PLS-00904: insufficient privilege to access object DBMS_AQADM_SYSCALLS
ORA-06550: line 4, column 3:
PL/SQL: Statement ignored
dbms_aqadm_syscalls.get_owner_instance(
primary_instance IN BINARY_INTEGER,
secondary_instance IN BINARY_INTEGER,
curr_owner_instance IN BINARY_INTEGER)
RETURN BINARY_INTEGER;
dbms_aqadm_syscalls.is_queue_replicated(
name_type IN BINARY_INTEGER,
qt_name IN VARCHAR2,
queue_name IN VARCHAR2,
crt_flag IN BOOLEAN,
ext_flag IN BOOLEAN,
replication_mode IN BINARY_INTEGER,
can_obj_name OUT VARCHAR2,
can_obj_sch OUT VARCHAR2,
iqrepl OUT BOOLEAN,
current_user IN VARCHAR2);
dbms_aqadm_syscalls.kwqa_3gl_addsubscriber(
q_schema IN VARCHAR2,
q_name IN VARCHAR2,
sub IN sys.aq$_agent,
sub_type IN NUMBER,
rule IN VARCHAR2,
trans_owner IN VARCHAR2,
trans_name IN VARCHAR2,
ruleset_owner IN VARCHAR2,
ruleset_name IN VARCHAR2,
negrset_owner IN VARCHAR2,
negrset_name IN VARCHAR2,
sub_id IN NUMBER,
proxy_id IN NUMBER,
proxy_addr IN VARCHAR2,
addr_id IN NUMBER,
creation_time IN TIMESTAMP WITH TIME ZONE,
scn_at_add OUT NUMBER);
dbms_aqadm_syscalls.kwqa_3gl_alterqueue(
owner IN VARCHAR2,
queue_name IN VARCHAR2,
max_retry IN BINARY_INTEGER,
retry_interval IN BINARY_INTEGER,
retention IN BINARY_INTEGER,
comment IN VARCHAR2,
flow_control IN BINARY_INTEGER,
rep_queue IN BINARY_INTEGER);
dbms_aqadm_syscalls.kwqa_3gl_altersubscriber(
q_schema IN VARCHAR2,
q_name IN VARCHAR2,
sub IN sys.aq$agent,
new_rule_name IN VARCHAR2,
ex_rule_name IN VARCHAR2,
new_trans_name IN VARCHAR2,
full_ruleset IN VARCHAR2,
ex_ruleset IN VARCHAR2,
full_negrset IN VARCHAR2,
ex_negrset IN VARCHAR2,
modification_time IN TIMESTAMP WITH TIME ZONE,
current_user IN VARCHAR2)
dbms_aqadm_syscalls.kwqa_3gl_analyze_msg_cache(
inst_id IN BINARY_INTEGER,
schema IN VARCHAR2,
qname IN VARCHAR2,
queue_id IN BINARY_INTEGER,
pdb IN BINARY_INTEGER,
input_flag IN BINARY_INTEGER);
dbms_aqadm_syscalls.kwqa_3gl_createadtplodinfo(
owner IN VARCHAR2,
queue_name IN VARCHAR2,
adt_schema IN VARCHAR2,
adt_name IN VARCHAR2,
qt_flags IN BINARY_INTEGER);
dbms_aqadm_syscalls.kwqa_3gl_createcacheobject(
destination IN VARCHAR2,
jobname IN VARCHAR2,
duration IN NUMBER,
myoid IN RAW,
latency IN NUMBER,
destq IN BINARY_INTEGER);
dbms_aqadm_syscalls.kwqa_3gl_createqueue(
owner IN VARCHAR2,
queue_name IN VARCHAR2,
table_name IN VARCHAR2,
compatible IN BINARY_INTEGER,
queue_oid IN RAW,
queue_type IN BINARY_INTEGER,
max_retry IN BINARY_INTEGER,
retry_interval IN BINARY_INTEGER,
tracking IN BOOLEAN,
retention IN BINARY_INTEGER,
owner_instance IN BINARY_INTEGER,
comment IN VARCHAR2,
qt_flags IN BINARY_INTEGER,
sort_order IN BINARY_INTEGER,
timezone IN VARCHAR2,
create_import IN BOOLEAN,
shard_count IN BINARY_INTEGER);
dbms_aqadm_syscalls.kwqa_3gl_createqueue_12g(
owner IN VARCHAR2,
queue_name IN VARCHAR2,
table_name IN VARCHAR2,
compatible IN BINARY_INTEGER,
queue_oid IN RAW,
queue_type IN BINARY_INTEGER,
max_retry IN BINARY_INTEGER,
retry_interval IN BINARY_INTEGER,
tracking IN BOOLEAN,
retention IN BINARY_INTEGER,
owner_instance IN BINARY_INTEGER,
comment IN VARCHAR2,
qt_flags IN BINARY_INTEGER,
timezone IN VARCHAR2,
create_import IN BOOLEAN);
dbms_aqadm_syscalls.kwqa_3gl_grant(
owner IN VARCHAR2,
queue_name IN VARCHAR2,
grantee IN VARCHAR2,
privilege IN BINARY_INTEGER,
is_syspriv IN PL/SQL BOOLEAN,
cascade IN BOOLEAN,
grantor IN VARCHAR2);
dbms_aqadm_syscalls.kwqa_3gl_lockqueue(
q_schema IN VARCHAR2,
q_name IN VARCHAR2,
operation IN VARCHAR2,
flags IN BINARY_INTEGER,
ignore_errors IN BOOLEAN);
dbms_aqadm_syscalls.kwqa_3gl_lockqueuetable(
qt_schema IN VARCHAR2,
qt_name IN VARCHAR2,
operation IN VARCHAR2,
flags IN BINARY_INTEGER);
TBD
Overload 2
dbms_aqadm_syscalls.kwqa_3gl_lockqueuetable(
qt_schema IN VARCHAR2,
qt_name IN VARCHAR2,
operation IN VARCHAR2,
flags IN BINARY_INTEGER,
qtab_exists OUT BOOLEAN,
qtdct_exists OUT BOOLEAN,
qtobjno OUT NUMBER,
qt_flags OUT BINARY_INTEGER,
qt_owner OUT BINARY_INTEGER);
dbms_aqadm_syscalls.kwqa_3gl_parseaqname(
ntype IN BINARY_INTEGER,
fname IN VARCHAR2,
default_schema IN VARCHAR2,
schema OUT VARCHAR2,
name OUT VARCHAR2,
dblkdb OUT VARCHAR2,
dblkdom OUT VARCHAR2,
dblkconq OUT VARCHAR2,
ext_flag IN BINARY_INTEGER);
dbms_aqadm_syscalls.kwqa_3gl_purgeremsublist(
owner IN VARCHAR2,
queue_name IN VARCHAR2,
sub IN sys.aq$agent,
subid IN NUMBER,
ifcheck IN BOOLEAN,
pendingtxnx OUT BOOLEAN);
dbms_aqadm_syscalls.kwqa_3gl_purge_cbk_obj(
schema IN VARCHAR2,
name IN VARCHAR2,
qt_flags IN BINARY_INTEGER,
tobjno IN NUMBER,
qt_sort_cols IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER,
purge_condition IN VARCHAR2);
dbms_aqadm_syscalls.kwqa_3gl_purge_queue_table(
schema IN VARCHAR2,
name IN VARCHAR2,
qt_flags IN BINARY_INTEGER,
tobjno IN NUMBER,
qt_sort_cols IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER,
purge_condition IN VARCHAR2,
current_user IN VARCHAR2,
jms IN BOOLEAN);
dbms_aqadm_syscalls.kwqa_3gl_removesubscriber(
q_schema IN VARCHAR2,
q_name IN VARCHAR2,
sub IN OBJECT, SYS AQ$_AGENT
rule_name IN VARCHAR2,
ruleset IN VARCHAR2,
negrset IN VARCHAR2,
subid IN NUMBER,
proxyid IN NUMBER,
deletion_time IN TIMESTAMP WITH TIME ZONE,
scn_at_remove OUT NUMBER,
current_user IN VARCHAR2);
dbms_aqadm_syscalls.kwqa_3gl_revoke(
owner IN VARCHAR2,
queue_name IN VARCHAR2,
grantee IN VARCHAR2,
privilege IN BINARY_INTEGER,
is_syspriv IN BOOLEAN,
grantor IN VARCHAR2);
dbms_aqadm_syscalls.kwqa_3gl_setregistrationname(
regname OUT VARCHAR2,
qschema IN VARCHAR2,
qname IN VARCHAR2,
dest IN VARCHAR2,
delim IN VARCHAR2,
destq IN BINARY_INTEGER);
dbms_aqadm_syscalls.kwqa_3gl_set_table_stats_lock(
ownname IN VARCHAR2,
objname IN VARCHAR2,
objsubname IN VARCHAR2,
dslckmode IN BINARY_INTEGER,
cslckmode IN BINARY_INTEGER);
dbms_aqadm_syscalls.kwqa_3gl_stop_msg_forwarding(
schema IN VARCHAR2,
qname IN VARCHAR2,
queue_id IN BINARY_INTEGER,
pdb IN BINARY_INTEGER,
shard_id IN BINARY_INTEGER,
subscriber_id IN BINARY_INTEGER,
destination_inst_id IN BINARY_INTEGER);
dbms_aqadm_syscalls.kwqa_3gl_updkgqm(
qid IN NUMBER,
qschema IN VARCHAR2,
qname IN VARCHAR2,
flow_control IN BINARY_INTEGER,
op IN BINARY_INTEGER,
force IN BOOLEAN);