| General Information |
| Purpose |
Administration of Advanced Queue queuing |
| Source |
/rdbms/admin/dbmsaqad.sql
also see: /rdbms/admin/catqueue.sql |
Constants |
Constant |
DataType |
Value |
| Delivery Mode |
| PERSISTENT |
BINARY_INTEGER |
1 |
| BUFFERED |
BINARY_INTEGER |
2 |
| PERSISTENT_OR_BUFFERED |
BINARY_INTEGER |
3 |
| |
| Get/Set_replay_info |
| LAST_ENQUEUED |
BINARY_INTEGER |
0 |
| LAST_ACKNOWLEDGED |
BINARY_INTEGER |
1 |
| |
| LDAP |
| AQ_QUEUE_CONNECTION |
BINARY_INTEGER |
1 |
| AQ_TOPIC_CONNECTION |
BINARY_INTEGER |
2 |
| |
| Message Grouping |
| NONE |
BINARY_INTEGER |
0 |
| TRANSACTIONAL |
BINARY_INTEGER |
1 |
| |
|
|
| Non-Repudiation Properties |
|
|
| NON_REPUDIATE_SENDER |
BINARY_INTEGER |
1 |
| NON_REPUDIATE_SNDRCV |
BINARY_INTEGER |
2 |
| |
| Protocols |
| TTC |
BINARY_INTEGER |
0 |
| HTTP |
BINARY_INTEGER |
1 |
| SMTP |
BINARY_INTEGER |
2 |
| FTP |
BINARY_INTEGER |
4 |
| ANYP |
BINARY_INTEGER |
HTTP + SMTP |
| LOGMINER_PROTOCOL |
BINARY_INTEGER |
1 |
| LOGAPPLY_PROTOCOL |
BINARY_INTEGER |
2 |
| TEST_PROTOCOL |
BINARY_INTEGER |
3 |
| |
| Queue Types |
| NORMAL_QUEUE |
BINARY_INTEGER |
0 |
| EXCEPTION_QUEUE |
BINARY_INTEGER |
1 |
| NON_PERSISTENT_QUEUE |
BINARY_INTEGER |
2 |
| |
| Retention |
| INFINITE |
BINARY_INTEGER |
-1 |
| |
| Subscriber |
| QUEUE_TO_QUEUE_SUBSCRIBER |
BINARY_INTEGER |
8 |
|
Data Dictionary Tables & Views |
gv
AQ_EVENT_TABLE
AQ
AQ
AQ
AQ
AQ
AQ
| DBA |
ALL |
USER |
| dba_evaluation_contexts |
all_evaluation_contexts |
user_evaluation_contexts |
| dba_evaluation_context _tables |
all_evaluation_context _tables |
user_evaluation_context _tables |
| dba_queues |
all_queues |
user_queues |
| dba_queue_publishers |
all_queue_publishers |
user_queue_publishers |
| dba_queue_schedules |
all_queue_schedules |
user_queue_schedules |
| dba_queue_tables |
all_queue_tables |
user_queue_tables |
| dba_rule_sets |
all_rule_sets |
user_rule_sets |
| dba_rulesets |
all_rulesets |
user_rulesets |
| dba_source |
all_source |
user_source |
| dba_types |
all_types |
user_types |
|
Defined Data Types |
TYPE aq AS OBJECT (
name VARCHAR2(30), --
name of message producer or consumer
address VARCHAR2(1024), -- address where message to be sent
protocol NUMBER DEFAULT 0); -- must be 0
/
TYPE aq IS
RECORD(block BOOLEAN DEFAULT FALSE,
delivery_mode PLS_INTEGER DEFAULT dbms_aqadm.persistent);
/
TYPE aq IS TABLE OF sys.aq
INDEX BY BINARY_INTEGER;
/ |
Dependencies |
| AQ |
DBA_QUEUE_TABLES |
| AQ |
DBMS_AQ |
| AQ |
DBMS_AQADM |
| AQ |
DBMS_AQELM |
| AQ |
DBMS_AQIN |
| DBA_AQ_AGENTS |
DBMS_AQJMS_INTERNAL |
| DBA_AQ_AGENT_PRIVS |
DBMS_AQ_IMPORT_INTERNAL |
| DBA_QUEUES |
DBMS_RULE_EXIMP |
| DBA_QUEUE_SCHEDULES |
DBMS_TRANSFORM |
| DBA_QUEUE_SUBSCRIBERS |
GV_ |
|
| init.ora Parameters |
aq_tm_processes has been deprecated in 10g.
Job_Queue_processes must be set to a minimum of 2. |
| job_queue_processes=2 |
| Note |
The AUTOCOMMIT parameter is deprecated as of
10gR2. |
| Parameters |
Parameter |
Options |
| message_grouping |
TRANSACTIONAL, NONE |
| queue_type |
NORMAL_QUEUE, EXCEPTION_QUEUE, NON_PERSISTENT_QUEUE |
| retention |
0, 1, 2 ... INFINITE |
|
System Privileges |
grant execute on dbms_aqadm to <schema_name>;
grant execute on dbms_aq to <schema_name>;
GRANT aq_administrator_role
TO <schema_name> IDENTIFIED BY <password>;
GRANT execute ON dbms_aqadm TO
<schema_name>; |
GRANT aq_administrator_role TO
aqadmin
IDENTIFIED BY "Res1ric1ed";
GRANT execute ON dbms_aqadm TO aqadmin; |
| |
| Alias Subprograms |
| ADD_ALIAS_TO_LDAP |
| Creates an alias for a queue, agent, or a JMS ConnectionFactory in
LDAP |
dbms_aqadm.add_alias_to_ldap(
alias IN VARCHAR2,
obj_location IN VARCHAR2); |
| TBD |
| |
| ADD_CONNECTION_TO_LDAP |
Add a connection string to LDAP directory
Overload 1 |
dbms_aqadm.add_connection_to_ldap(
connection IN VARCHAR2,
host IN VARCHAR2,
port IN BINARY_INTEGER,
sid IN VARCHAR2,
driver IN VARCHAR2 DEFAULT NULL,
type IN BINARY_INTEGER DEFAULT
AQ_QUEUE_CONNECTION); |
| TBD |
| Overload 2 |
dbms_aqadm.add_connection_to_ldap(
connection IN VARCHAR2,
jdbc_string IN VARCHAR2,
username IN VARCHAR2 DEFAULT NULL,
password IN VARCHAR2 DEFAULT NULL,
type IN BINARY_INTEGER DEFAULT AQ_QUEUE_CONNECTION); |
| TBD |
| |
| DEL_ALIAS_FROM_LDAP |
| Drops an alias for a queue, agent, or JMS ConnectionFactory in LDAP |
dbms_aqadm.del_alias_from_ldap(alias IN VARCHAR2); |
| exec dbms_aqadm.del_alias_from_ldap(? |
| |
| DEL_CONNECTION_FROM_LDAP |
| Drops
a connection string from an LDAP directory |
dbms_aqadm.add_connection_to_ldap(connection IN VARCHAR2); |
| TBD |
| |
| Notification Subprograms |
| GET_WATERMARK |
| Retrieves the value of watermark set by
SET_WATERMARK |
dbms_aqadm.get_watermark(wmvalue OUT NUMBER); |
set serveroutput on
DECLARE
x NUMBER;
BEGIN
dbms_aqadm.set_watermark(1);
dbms_aqadm.get_watermark(x);
dbms_output.put_line(x);
dbms_aqadm.set_watermark(10);
dbms_aqadm.get_watermark(x);
dbms_output.put_line(x);
END;
/ |
| |
| SET_WATERMARK |
| Used for Oracle Streams AQ notification to specify and
limit memory use |
dbms_aqadm.set_watermark(wmvalue IN NUMBER); |
| See GET_WATERMARK entry |
| |
| Privilege Subprograms |
| GRANT_QUEUE_PRIVILEGE |
| Grants privileges on a queue
to a users or role |
dbms_aqadm.grant_queue_privilege (
privilege IN VARCHAR2,
queue_name IN VARCHAR2,
grantee IN VARCHAR2,
grant_option IN BOOLEAN := FALSE);
Choices:
ENQUEUE, DEQUEUE, ALL |
| See AQ Demo 1 |
| |
| GRANT_SYSTEM_PRIVILEGE |
| Grants Oracle Streams AQ system privileges to users and
roles |
dbms_aqadm.grant_system_privilege (
privilege IN VARCHAR2,
grantee IN VARCHAR2,
admin_option IN BOOLEAN := FALSE);
Choices: ENQUEUE_ANY, DEQUEUE_ANY, MANAGE_ANY |
| See AQ Demo 1 |
| |
| REVOKE_QUEUE_PRIVILEGE |
| Revokes privileges on a
queue from a user or role |
dbms_aqadm.revoke_queue_privilege (
privilege IN VARCHAR2,
queue_name IN VARCHAR2,
grantee IN VARCHAR2);
Choices: ENQUEUE_ANY, DEQUEUE_ANY, MANAGE_ANY |
| exec
dbms_aqadm.revoke_queue_privilege(ENQUEUE_ANY,'rx_queue', 'UWCLASS'); |
| |
| REVOKE_SYSTEM_PRIVILEGE |
| revokes Oracle Streams AQ system privileges from users and roles |
dbms_aqadm.revoke_system_privilege(
privilege IN VARCHAR2,
grantee IN VARCHAR2);
Choices: ENQUEUE_ANY, DEQUEUE_ANY, MANAGE_ANY |
| exec
dbms_aqadm.revoke_system_privilege(ENQUEUE_ANY, 'UWCLASS'); |
| |
| Propagation Subprograms |
| ALTER_PROPAGATION_SCHEDULE |
| Alters parameters for a propagation schedule |
dbms_aqadm.alter_propagation_schedule(
queue_name IN VARCHAR2,
destination IN VARCHAR2 DEFAULT NULL,
duration IN NUMBER
DEFAULT NULL,
next_time IN VARCHAR2 DEFAULT NULL,
latency IN NUMBER
DEFAULT 60,
destination_queue IN VARCHAR2 DEFAULT NULL); |
| exec
dbms_aqadm.alter_propagation_schedule('rx_queue', 'finance_link'); |
| |
| DISABLE_PROPAGATION_SCHEDULE |
| Disable a propagation schedule |
dbms_aqadm.disable_propagation_schedule (
queue_name IN VARCHAR2,
destination IN VARCHAR2 DEFAULT NULL,
destination_queue IN VARCHAR2 DEFAULT NULL); |
| exec
dbms_aqadm.disable_propagation_schedule('rx_queue', finance_link'); |
| |
| ENABLE_PROPAGATION_SCHEDULE |
| Enables a
previously disabled
propagation schedule |
dbms_aqadm.enable_propagation_schedule (
queue_name IN VARCHAR2,
destination IN VARCHAR2 DEFAULT NULL,
destination_queue IN VARCHAR2 DEFAULT NULL); |
| exec
dbms_aqadm.enable_propagation_schedule('rx_queue', 'finance_link'); |
| |
| GET_PROP_SEQNO |
| Undocumented |
dbms_aqadm.get_prop_seqno(
qid IN BINARY_INTEGER,
dqname IN VARCHAR2,
dbname IN VARCHAR2,
seq OUT BINARY_INTEGER); |
| TBD |
| |
| RECOVER_PROPAGATION |
| Undocumented |
dbms_aqadm.recover_propagation(
schema IN VARCHAR2,
queue_name IN VARCHAR2,
destination IN VARCHAR2,
protocol IN BINARY_INTEGER DEFAULT TTC,
url IN VARCHAR2
DEFAULT NULL,
username IN VARCHAR2
DEFAULT NULL,
passwd IN VARCHAR2
DEFAULT NULL,
trace IN BINARY_INTEGER DEFAULT 0); |
| TBD |
| |
| SCHEDULE_PROPAGATION |
Schedules propagation of
messages from a queue to
a destination identified by a
specific database link |
dbms_aqadm.schedule_propagation (
queue_name IN VARCHAR2,
destination IN VARCHAR2 DEFAULT NULL,
start_time IN
DATE DEFAULT NULL,
duration IN NUMBER
DEFAULT NULL,
next_time IN VARCHAR2 DEFAULT NULL,
latency IN NUMBER
DEFAULT 60,
destination_queue IN VARCHAR2 DEFAULT NULL);
-- Note: The file in /rdbms/admin shows start_time as data type
TIMESTAMP WITH TIMEZONE but all_arguments does not. |
| See AQ Demo 1 |
| |
| UNSCHEDULE_PROPAGATION |
| Unschedules previously
scheduled propagation of
messages from a queue to
a destination identified by
a specific database link |
dbms_aqadm.unschedule_propagation (
queue_name IN VARCHAR2,
destination IN VARCHAR2 DEFAULT NULL,
destination_queue IN VARCHAR2 DEFAULT NULL); |
| exec dbms_aqadm.unschedule_propagation('rx_queue',
'finance_link'); |
| |
| VERIFY_QUEUE_TYPES |
Verifies that the source
and destination queues
have identical types |
dbms_aqadm.verify_queue_types (
src_queue_name IN VARCHAR2,
dest_queue_name IN VARCHAR2,
destination IN VARCHAR2 DEFAULT NULL,
rc
OUT
BINARY_INTEGER
transformation IN VARCHAR2 DEFAULT NULL); |
set serveroutput on
DECLARE
x BINARY_INTEGER;
BEGIN
dbms_aqadm.verify_queue_types('rx_queue',
'finance_queue', 'finance_link', x);
dbms_output.put_line(x);
END;
/ |
| |
| Queue Subprograms |
| ALTER_QUEUE |
| Alters an existing queue |
dbms_aqadm.alter_queue (
queue_name IN VARCHAR2,
max_retries IN NUMBER DEFAULT NULL,
retry_delay IN NUMBER DEFAULT NULL,
retention_time IN NUMBER DEFAULT NULL,
auto_commit IN BOOLEAN DEFAULT TRUE,
comment IN VARCHAR2 DEFAULT NULL); |
| exec dbms_aqadm.alter_queue(queue_name=>'rx_queue', retry_delay=>2, comment=> 'Retry delay set to 2
seconds'); |
| |
| CREATE_NP_QUEUE |
Create a nonpersistent
RAW queue
Deprecated in 10gR2 |
dbms_aqadm.create_np_queue (
queue_name IN VARCHAR2,
multiple_consumers IN BOOLEAN DEFAULT FALSE,
comment IN VARCHAR2
DEFAULT NULL); |
| exec dbms_aqadm.create_np_queue('rx_np_q', TRUE,
'Non-persistant queue'); |
| |
| CREATE_QUEUE |
Creates a queue in the specified queue table |
dbms_aqadm.create_queue (
queue_name IN VARCHAR2,
queue_table IN VARCHAR2,
queue_type IN BINARY_INTEGER DEFAULT
NORMAL_QUEUE,
max_retries IN NUMBER
DEFAULT NULL,
retry_delay IN NUMBER
DEFAULT 0,
retention_time IN NUMBER
DEFAULT 0,
dependency_tracking IN BOOLEAN DEFAULT FALSE,
comment
IN
VARCHAR2 DEFAULT NULL,
auto_commit IN BOOLEAN
DEFAULT TRUE); |
| See AQ Demo 1 |
| |
| DROP_QUEUE |
| Drops an existing queue |
dbms_aqadm.drop_queue (
queue_name IN VARCHAR2,
auto_commit IN BOOLEAN DEFAULT TRUE); |
| See AQ Demo 1 |
| |
| START_QUEUE |
| Enables the specified queue for enqueuing or dequeuing |
dbms_aqadm.start_queue (
queue_name IN VARCHAR2,
enqueue IN BOOLEAN DEFAULT TRUE,
dequeue IN BOOLEAN DEFAULT TRUE); |
| See AQ Demo 1 |
| |
| STOP_QUEUE |
| Disables enqueuing or dequeuing on the specified queue. |
dbms_aqadm.stop_queue (
queue_name IN VARCHAR2,
enqueue IN BOOLEAN DEFAULT TRUE,
dequeue IN BOOLEAN DEFAULT TRUE,
wait IN BOOLEAN DEFAULT TRUE); |
| See AQ Demo 1 |
| |
| Queue Table Subprograms |
| ALTER_QUEUE_TABLE |
| Alters the existing properties of a queue
table for use with RAC |
dbms_aqadm.alter_queue_table (
queue_table IN VARCHAR2,
comment IN VARCHAR2
DEFAULT NULL,
primary_instance IN BINARY_INTEGER DEFAULT NULL,
secondary_instance IN BINARY_INTEGER DEFAULT NULL); |
| exec dbms_aqadm.alter_queue_table('rx_queue_table', 'Prescription Queue Table', 1, 2); |
| |
| CREATE_QUEUE_TABLE |
Creates a queue table for messages of a predefined
type |
dbms_aqadm.create_queue_table(
queue_table IN VARCHAR2,
queue_payload_type IN VARCHAR2,
storage_clause IN VARCHAR2
DEFAULT NULL,
sort_list IN VARCHAR2
DEFAULT NULL,
multiple_consumers IN BOOLEAN DEFAULT FALSE,
message_grouping IN BINARY_INTEGER DEFAULT NONE,
comment IN VARCHAR2
DEFAULT NULL,
auto_commit IN BOOLEAN
DEFAULT TRUE,
primary_instance IN BINARY_INTEGER DEFAULT 0,
secondary_instance IN BINARY_INTEGER DEFAULT 0,
compatible IN VARCHAR2
DEFAULT NULL,
non_repudiation IN BINARY_INTEGER DEFAULT 0,
secure
IN BOOLEAN DEFAULT FALSE); |
| See AQ Demo 1 |
| |
| DROP_QUEUE_TABLE |
| Drops an existing queue table |
dbms_aqadm.drop_queue_table (
queue_table IN VARCHAR2,
force IN BOOLEAN DEFAULT FALSE,
auto_commit IN BOOLEAN DEFAULT TRUE); |
| See AQ Demo 1 |
| |
| ENABLE_JMS_TYPES |
| Enqueue of JMS types and XML types does not work with Oracle Streams Sys.Anydata queues unless you call this procedure after
DBMS_STREAMS_ADM. SET_UP_QUEUE |
dbms_aqadm.enable_jms_types(queue_table IN VARCHAR2); |
| TBD |
| |
| MIGRATE_QUEUE_TABLE |
| Upgrade a
queue table from ver 8.0 to ver 8.1 or higher compatibility |
dbms_aqadm.migrate_queue_table(
queue_table IN VARCHAR2,
compatible IN VARCHAR2); |
| exec dbms_aqadm.migrate_queue_table('legacy_tab',
'8.1'); |
| |
| PURGE_QUEUE_TABLE |
Purges messages from
the named queue table |
dbms_aqadm.purge_queue_table(
queue_table IN VARCHAR2,
purge_condition IN VARCHAR2,
purge_options IN aq); |
DECLARE
po_t dbms_aqadm.aq;
BEGIN
dbms_aqadm.purge_queue_table('RX_QUEUE_TABLE',
NULL, po_t);
END;
/ |
| |
| Streams AQ Agent Subprograms |
| ALTER_AQ_AGENT |
| Alters an agent registered for Oracle Streams AQ Internet access |
dbms_aqadm.alter_aq_agent(
agent_name IN VARCHAR2,
certificate_location IN VARCHAR2 DEFAULT NULL,
enable_http IN BOOLEAN DEFAULT FALSE,
enable_smtp IN BOOLEAN DEFAULT FALSE,
enable_anyp IN BOOLEAN DEFAULT FALSE); |
| exec dbms_aqadm.alter_aq_agent(agent_name=>'UWAGENT',
enable_http=>TRUE, enable_smtp=>TRUE); |
| |
| CREATE_AQ_AGENT |
| Creates an Internet access agent |
dbms_aqadm.create_aq_agent(
agent_name IN VARCHAR2,
certificate_location IN VARCHAR2 DEFAULT NULL,
enable_http IN BOOLEAN
DEFAULT FALSE,
enable_smtp IN BOOLEAN
DEFAULT FALSE,
enable_anyp IN BOOLEAN
DEFAULT FALSE ) |
exec
dbms_aqadm.create_aq_agent(agent_name=>'UWAGENT',
certificate_location=>'cn=uwclass,cn=psoug,cn=org', enable_http=>TRUE; |
| |
| DISABLE_DB_ACCESS |
| Revokes the privileges of a specific database
user from an Oracle Streams AQ Internet agent |
dbms_aqadm.disable_db_access(
agent_name IN VARCHAR2,
db_username IN VARCHAR2); |
| exec
dbms_aqadm.disable_aq_agent('UWAGENT', 'UWCLASS'); |
| |
| DROP_AQ_AGENT |
|
Drops an agent that was previously registered for Oracle Streams AQ Internet access |
dbms_aqadm.drop_aq_agent(agent_name IN VARCHAR2); |
|
exec dbms_aqadm.drop_aq_agent('UWCLASS'); |
| |
| ENABLE_DB_ACCESS |
| Grants an AQ Internet agent the privileges of a
specific database user |
dbms_aqadm.enable_db_access(
agent_name IN VARCHAR2,
db_username IN VARCHAR2) |
| exec
dbms_aqadm.enable_db_access('UWAGENT', 'UWCLASS'); |
| |
| Subscriber Subprograms |
| ADD_SUBSCRIBER |
Adds a default subscriber to
a queue |
dbms_aqadm.add_subscriber(
queue_name IN VARCHAR2,
subscriber IN sys.aq,
rule IN VARCHAR2 DEFAULT NULL,
transformation IN VARCHAR2 DEFAULT NULL
queue_to_queue IN BOOLEAN DEFAULT FALSE,
delivery_mode IN PLS_INTEGER DEFAULT dbms_aqadm.persistent);
|
See AQ Demo 1
-- a rule based on a VARCHAR2 must be in the format:
'priority < 11 AND SOURCE = ''EF'''); |
| |
| ALTER_SUBSCRIBER |
Alters existing properties of a subscriber to a specified queue. Only the rule can be altered
Overload 1 |
dbms_aqadm.alter_subscriber (
queue_name IN VARCHAR2,
subscriber IN sys.aq,
rule IN VARCHAR2); |
DECLARE
q_subsc sys.aq;
BEGIN
q_subsc := sys.aq('outpatient_rx', NULL, NULL);
dbms_aqadm.alter_subscriber('rx_queue', q_subsc, 'priority < 10');
END;
/ |
| Overload 2 |
dbms_aqadm.alter_subscriber (
queue_name IN VARCHAR2,
subscriber IN sys.aq,
rule IN VARCHAR2
transformation IN VARCHAR2); |
| TBD |
| |
| QUEUE_SUBSCRIBERS |
| Returns the subscribers to an 8.0-compatible
multiconsumer queue in the PL/SQL index by table collection type DBMS_AQADM. AQ |
dbms_aqadm.queue_subscribers(queue_name IN VARCHAR2)
RETURN aq |
| TBD |
| |
| REMOVE_SUBSCRIBER |
| Removes a default subscriber from a queue |
dbms_aqadm.remove_subscriber (
queue_name IN VARCHAR2,
subscriber IN sys.aq); |
| exec
dbms_aqadm.remove_subscriber('rx_queue', 'uw_class'); |
| |
| Undocumented Subprograms |
| AQ |
Undocumented
Overload 1 |
aq(job IN NUMBER) RETURN DATE; |
| TBD |
Overload 2 |
aq(
job IN NUMBER,
next_date IN DATE,
qname IN VARCHAR2,
schema IN VARCHAR2,
destination IN VARCHAR2 DEFAULT NULL,
toid_char IN VARCHAR2 DEFAULT NULL,
version_char IN VARCHAR2 DEFAULT NULL,
start_time IN VARCHAR2,
duration IN VARCHAR2 DEFAULT NULL,
next_time IN VARCHAR2 DEFAULT NULL,
latency IN VARCHAR2 DEFAULT '60') RETURN DATE; |
| TBD |
| |
| GET_REPLAY_INFO
(new 11g) |
| Get a sender's replay info |
dbms_aqadm.get_replay_info(
queue_name IN VARCHAR2,
sender_agent IN sys.aq,
replay_attribute IN BINARY_INTEGER,
correlation OUT VARCHAR2); |
| TBD |
| |
| GET_TYPE_INFO |
Undocumented
Overload 1 |
dbms_aqadm.get_type_info(
schema IN VARCHAR2,
qname IN VARCHAR2,
gettds IN BOOLEAN,
rc OUT BINARY_INTEGER,
toid OUT RAW,
version OUT NUMBER,
tds OUT LONG RAW,
queue_style OUT VARCHAR2,
network_name OUT VARCHAR2); |
| TBD |
| Overload 2 |
dbms_aqadm.get_type_info(
schema IN VARCHAR2,
qname IN VARCHAR2,
gettds IN BOOLEAN,
rc OUT BINARY_INTEGER,
toid OUT RAW,
version OUT NUMBER,
tds OUT LONG RAW); |
| TBD |
| |
| GRANT_TYPE_ACCESS |
| Undocumented |
dbms_aqadm.grant_type_access(user_name IN VARCHAR2); |
| TBD |
| |
| NONREPUDIATE_RECEIVER |
Non-repudiate
receiver of ADT payload
Overload 1 |
dbms_aqadm.nonrepudiate_receiver(
queue_name IN VARCHAR2,
msgid IN RAW,
rcver_info IN sys.aq,
signature OUT sys.aq,
payload OUT "<ADT_1>"); |
| TBD |
Non-repudiate
receiver of raw payload
Overload 2 |
dbms_aqadm.nonrepudiate_receiver(
queue_name IN VARCHAR2,
msgid IN RAW,
rcver_info IN sys.aq,
signature OUT sys.aq,
payload OUT RAW); |
| TBD |
| |
| NONREPUDIATE_SENDER |
Non-repudiate sender of ADT payload
Overload 1 |
dbms_aqadm.nonrepudiate_sender(
queue_name IN VARCHAR2,
msgid IN RAW,
sender_info IN sys.aq,
signature OUT sys.aq,
payload OUT "<ADT_1>"); |
| TBD |
Non-repudiate sender of raw payload
Overload 2 |
dbms_aqadm.nonrepudiate_sender(
queue_name IN VARCHAR2,
msgid IN RAW,
sender_info IN sys.aq,
signature OUT sys.aq,
payload OUT RAW);
|
| TBD |
| |
| RESET_REPLAY_INFO
(new 11g) |
| Reset sender's replay info |
dbms_aqadm.reset_replay_info(
queue_name IN VARCHAR2,
sender_agent IN sys.aq,
replay_attribute IN BINARY_INTEGER); |
| TBD |
| |
| SET_SESSION_EVENT |
| Set a
session event
dbms_aqadm.set_session_event is an undocumented procedure in
Oracle 11.1.0.6.0 that has been removed in 11.1.0.7.0.
|
dbms_aqadm.set_session_event(
eventno IN VARCHAR2,
tracelevel IN VARCHAR2); |
| exec
dbms_aqadm.set_session_event('10046', '12'); |
| |
| START_TIME_MANAGER |
| Undocumented |
dbms_aqadm.start_time_manager; |
| exec dbms_aqadm.start_time_manager; |
| |
| STOP_TIME_MANAGER |
| Undocumented |
dbms_aqadm.stop_time_manager; |
| exec dbms_aqadm.stop_time_manager; |
| |
| VERIFY_QUEUE_TYPES_GET_NRP |
| Undocumented |
dbms_aqadm.verify_queue_types_get_nrp(
src_queue_name IN VARCHAR2,
dest_queue_name IN VARCHAR2,
destination IN VARCHAR2 DEFAULT NULL,
rc
OUT BINARY_INTEGER,
transformation IN VARCHAR2 DEFAULT NULL); |
| TBD |
| |
| VERIFY_QUEUE_TYPES_NO_QUEUE |
| Undocumented |
dbms_aqadm.verify_queue_types_no_queue(
src_queue_name IN VARCHAR2,
dest_queue_name IN VARCHAR2,
destination IN VARCHAR2 DEFAULT NULL,
rc OUT BINARY_INTEGER,
transformation IN VARCHAR2 DEFAULT NULL); |
| TBD |
Free