CODE
Oracle Code Library
JOBS
Find Or Post Oracle Jobs
FORUM
Oracle Discussion & Chat
PSOUG Home Code Snippets Oracle Reference Oracle Functions PSOUG Forum Oracle Blogs Bookmark and Share
 
 Search the Reference Library pages:  

Free
Oracle Magazine
Subscriptions
and Oracle White Papers

 

Oracle DBMS_AQADM

Version 11.1
 
General Information
Purpose Administration of Advanced Queue queuing
Source $ORACLE_HOME/rdbms/admin/dbmsaqad.sql

also see: $ORACLE_HOME/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
AQ_EVENT_TABLE
AQ$_INTERNET_USERS
AQ$_QUEUE_STATISTICS
AQ$_PENDING_MESSAGES
AQ$_PROPAGATION_STATUS
AQ$_MESSAGE_TYPES
AQ$_SCHEDULES
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$_agent 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$_purge_options_t IS
RECORD(block  BOOLEAN     DEFAULT FALSE,
delivery_mode PLS_INTEGER DEFAULT dbms_aqadm.persistent);
/

TYPE aq$_subscriber_list_t IS TABLE OF sys.aq$_agent
INDEX BY BINARY_INTEGER;
/

Dependencies
AQ$INTERNET_USERS DBA_QUEUE_TABLES
AQ$WM$EVENT_QUEUE_TABLE DBMS_AQ
AQ$WM$EVENT_QUEUE_TABLE_R DBMS_AQADM
AQ$WM$EVENT_QUEUE_TABLE_S DBMS_AQELM
AQ$_PROPAGATION_STATUS 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_$AQ
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$_purge_options_t);
DECLARE
 po_t dbms_aqadm.aq$_purge_options_t;
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$_agent,
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$_agent,
rule           IN VARCHAR2);
DECLARE
 q_subsc sys.aq$_agent;
BEGIN
  q_subsc := sys.aq$_agent('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$_agent,
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$_subscriber_list_t dbms_aqadm.queue_subscribers(queue_name IN VARCHAR2)
RETURN aq$_subscriber_list_t
TBD
 
REMOVE_SUBSCRIBER
Removes a default subscriber from a queue dbms_aqadm.remove_subscriber (
queue_name IN VARCHAR2,
subscriber IN sys.aq$_agent);
exec dbms_aqadm.remove_subscriber('rx_queue', 'uw_class');
 
Undocumented Subprograms
AQ$_PROPAQ
Undocumented

Overload 1
aq$_propaq(job IN NUMBER) RETURN DATE;
TBD

Overload 2
aq$_propaq(
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$_agent,
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$_agent,
signature  OUT sys.aq$_sig_prop,
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$_agent,
signature  OUT sys.aq$_sig_prop,
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$_agent,
signature   OUT sys.aq$_sig_prop,
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$_agent,
signature   OUT sys.aq$_sig_prop,
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$_agent,
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
 
Related Topics
Advanced Queuing Demo 1
Advanced Queuing Demo 2
DBMS_ALERT
DBMS_AQ
DBMS_JOB
DBMS_SERVER_ALERT
 
Home      :      Code Library      :      Sponsors      :      Privacy      :      Terms of Use      :      Contact Us [156 users online]    © 2010 psoug.org