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 queue management
AUTHID
CURRENT_USER
Constants
Name
Data Type
Value
DELAY
NO_DELAY
BINARY_INTEGER
0
DEQUEUE_MODE
BROWSE
BINARY_INTEGER
1
LOCKED
BINARY_INTEGER
2
REMOVE
BINARY_INTEGER
3
REMOVE_NODATA
BINARY_INTEGER
4
EXPIRATION
NEVER
BINARY_INTEGER
-1
NAMESPACE
NAMESPACE_ANONYMOUS
BINARY_INTEGER
0
NAMESPACE_AQ
BINARY_INTEGER
1
NAVIGATION
FIRST_MESSAGE
BINARY_INTEGER
1
NEXT_MESSAGE
BINARY_INTEGER
3
NEXT_TRANSACTION
BINARY_INTEGER
2
NTFN GROUPING CLASS
NTFN_GROUPING_CLASS_TIME
BINARY_INTEGER
1
NTFN GROUPING REPEAT COUNT
NTFN_GROUPING_FOREVER
BINARY_INTEGER
-1
NTFN GROUPING TYPE
NTFN_GROUPING_TYPE_LAST
BINARY_INTEGER
2
NTFN_GROUPING_TYPE_SUMMARY
BINARY_INTEGER
1
SEQUENCE
BEFORE
BINARY_INTEGER
2
TOP
BINARY_INTEGER
3
STATE
BUFFERED_EXPIRED
BINARY_INTEGER
10
DEFERRED
BINARY_INTEGER
8
EXPIRED
BINARY_INTEGER
3
PROCESSED
BINARY_INTEGER
2
READY
BINARY_INTEGER
0
WAITING
BINARY_INTEGER
1
VISIBILITY
IMMEDIATE
BINARY_INTEGER
1
ON_COMMIT
BINARY_INTEGER
2
WAIT
FOREVER
BINARY_INTEGER
-1
NO_WAIT
BINARY_INTEGER
0
Data Types
CREATE OR REPLACE TYPE sys.aq$_sig_prop AS OBJECT (
signature RAW(2000),
canalgo VARCHAR2(2000),
digalgo VARCHAR2(2000),
sigalgo VARCHAR2(2000),
certificate VARCHAR2(2000),
digval RAW(2000));
/
Message does not match criteria for any recipient or subscriber to the queue
ORA-25235
End of a transaction group
ORA-25254
time-out in LISTEN while waiting for a message
First Available
8.0
Security Model
Owned by SYS with EXECUTE granted to MDSYS,
SYSTEM, WMSYS, and the AQ_ADMINISTRATOR_ROLE, AQ_USER_ROLE, EXECUTE_CATALOG_ROLE, GSMADMIN_INTERNAL, GSMCATUSER
and OEM_MONITOR roles
dbms_aq.aq$_background_oper(
schema IN VARCHAR2,
queue_name IN VARCHAR2,
table_name IN VARCHAR2,
msgid IN RAW,
operation_time IN TIMESTAMP,
action IN BINARY_INTEGER,
subid IN BINARY_INTEGER,
intflag IN BINARY_INTEGER);
dbms_aq.aq$_delete_diot_tab(
schema IN VARCHAR2,
queue IN VARCHAR2,
delsql IN VARCHAR2,
subid IN NUMBER,
name IN VARCHAR2,
qid IN NUMBER,
msgid IN RAW);
dbms_aq.aq$_delete_hist_tab(
schema IN VARCHAR2,
queue IN VARCHAR2,
delsql IN VARCHAR2,
msgid IN RAW,
subid IN NUMBER,
name IN VARCHAR2,
address IN NUMBER);
dbms_aq.aq$_dequeue(
queue_name IN VARCHAR2,
subscriber IN VARCHAR2,
msgid IN RAW,
correlation IN VARCHAR2,
dequeue_mode IN BINARY_INTEGER,
nativation IN BINARY_INTEGER,
visibility IN BINARY_INTEGER,
wait IN BINARY_INTEGER,
enqueue_time OUT DATE,
state OUT BINARY_INTEGER,
out_msgid OUT RAW,
out_correlation OUT VARCHAR2,
priority OUT BINARY_INTEGER,
delay OUT BINARY_INTEGER,
expiration OUT BINARY_INTEGER,
attempts OUT BINARY_INTEGER,
exception_queue OUT VARCHAR2,
remote_recipients OUT dbms_aq.aq$_recipient_list_t,
sender_name OUT VARCHAR2,
sender_addr OUT VARCHAR2,
sender_protocol OUT BINARY_INTEGER,
orginal_msgid OUT RAW,
payload_type IN BINARY_INTEGER,
raw_user_data OUT RAW,
object_user_data OUT sys.standard.<ADT_1>,
deq_condition IN VARCHAR2,
signature IN sys.aq$_sig_prop,
out_sign OUT sys.aq$_sig_prop,
transformation IN VARCHAR2,
bufmesg_prop IN BINARY_INTEGER,
lcr2xml_convert IN BOOLEAN);
TBD
Overload 2
dbms_aq.aq$_dequeue(
queue_name IN VARCHAR2,
subscriber IN VARCHAR2,
msgid IN RAW,
correlation IN VARCHAR2,
dequeue_mode IN BINARY_INTEGER,
nativation IN BINARY_INTEGER,
visibility IN BINARY_INTEGER,
wait IN BINARY_INTEGER,
enqueue_time OUT DATE,
state OUT BINARY_INTEGER,
out_msgid OUT RAW,
out_correlation OUT VARCHAR2,
priority OUT BINARY_INTEGER,
delay OUT BINARY_INTEGER,
expiration OUT BINARY_INTEGER,
attempts OUT BINARY_INTEGER,
exception_queue OUT VARCHAR2,
remote_recipients OUT dbms_aq.aq$_recipient_list_t,
sender_name OUT VARCHAR2,
sender_addr OUT VARCHAR2,
sender_protocol OUT BINARY_INTEGER,
orginal_msgid OUT RAW,
payload_type IN BINARY_INTEGER,
raw_user_data OUT RAW,
object_user_data OUT sys.standard.<ADT_1>,
deq_condition IN VARCHAR2,
signature IN sys.aq$_sig_prop,
out_sign OUT
sys.aq$_sig_prop,
transformation IN VARCHAR2,
bufmesg_prop IN BINARY_INTEGER,
lcr2xml_convert IN BOOLEAN,
user_property OUT sys.anydata);
TBD
Overload 3
dbms_aq.aq$_dequeue(
queue_name IN VARCHAR2,
subscriber IN VARCHAR2,
msgid IN RAW,
correlation IN VARCHAR2,
dequeue_mode IN BINARY_INTEGER,
nativation IN BINARY_INTEGER,
visibility IN BINARY_INTEGER,
wait IN BINARY_INTEGER,
enqueue_time OUT DATE,
state OUT BINARY_INTEGER,
out_msgid OUT RAW,
out_correlation OUT VARCHAR2,
priority OUT BINARY_INTEGER,
delay OUT BINARY_INTEGER,
expiration OUT BINARY_INTEGER,
attempts OUT BINARY_INTEGER,
exception_queue OUT VARCHAR2,
remote_recipients OUT dbms_aq.aq$_recipient_list_t,
sender_name OUT VARCHAR2,
sender_addr OUT VARCHAR2,
sender_protocol OUT BINARY_INTEGER,
orginal_msgid OUT RAW,
payload_type IN BINARY_INTEGER,
raw_user_data OUT RAW,
object_user_data OUT sys.standard.<ADT_1>,
deq_condition IN VARCHAR2,
signature OBJECT IN sys.aq$_sig_prop,
out_sign OBJECT OUT sys.aq$_sig_prop,
transformation IN VARCHAR2,
bufmesg_prop IN BINARY_INTEGER,
lcr2xml_convert IN BOOLEAN,
user_property OUT sys.anydata,
delivery_mode IN BINARY_INTEGER,
out_delivery_mode OUT BINARY_INTEGER);
dbms_aq.aq$_enqueue(
queue_name IN VARCHAR2,
sender_name IN VARCHAR2,
sender_addr IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
orginal_msgid IN RAW,
correlation IN VARCHAR2,
visibility IN BINARY_INTEGER,
priority IN BINARY_INTEGER,
delay IN BINARY_INTEGER,
expiration IN BINARY_INTEGER,
relative_msgid IN RAW,
sequence_deviation IN BINARY_INTEGER,
exception_queue IN VARCHAR2,
recipients IN dbms_aq.aq$_recipient_list_t,
payload_type IN BINARY_INTEGER,
raw_user_data IN RAW,
object_user_data IN sys.standard.<ADT_1>,
msgid OUT RAW,
signature IN sys.aq$_sig_prop,
transformation IN VARCHAR2,
bufmesg_prop IN BINARY_INTEGER,
anydata_convert IN BOOLEAN,
lcr2xml_convert IN BOOLEAN,
user_property IN sys.anydata,
delivery_mode IN BINARY_INTEGER);
dbms_aq.aq$_insert_iot_tab(
schema IN VARCHAR2,
queue IN VARCHAR2,
inssql IN VARCHAR2,
subid IN NUMBER,
name IN VARCHAR2,
qid IN NUMBER,
eqtime IN TIMESTAMP,
step_no IN NUMBER,
priority IN NUMBER,
eq_txid IN VARCHAR2,
sender_id IN NUMBER,
txn_step IN NUMBER,
chn_no IN NUMBER,
lord_no IN NUMBER,
flags IN NUMBER,
msgid IN RAW);
dbms_aq.aq$_insert_hist_tab(
schema IN VARCHAR2,
queue IN VARCHAR2,
inssql IN VARCHAR2,
msgid IN RAW,
subid IN NUMBER,
name IN VARCHAR2,
address IN NUMBER);
dbms_aq.aq$_update_hist_tab(
schema IN VARCHAR2,
queue IN VARCHAR2,
updsql IN VARCHAR2,
deq_time IN TIMESTAMP WITH TIME ZONE,
deq_txid IN VARCHAR2,
deq_user IN VARCHAR2,
deq_uid IN NUMBER,
prop_msgid IN RAW,
rt_count IN NUMBER,
msgid IN RAW,
subid IN NUMBER,
sub_name IN VARCHAR2,
address IN NUMBER,
flag IN NUMBER);
dbms_aq.create_dequeue_job(
job_name OUT VARCHAR2,
queue_name IN VARCHAR2,
consumer_name IN VARCHAR2,
callback IN VARCHAR2,
ctx IN RAW,
comments IN VARCHAR2);
dbms_aq.dequeue(
queue_name IN VARCHAR2,
dequeue_options IN dbms_aq.dequeue_options_t,
message_properties OUT dbms_aq.message_properties_t,
payload OUT sys.standard.<OPAQUE_1>
msgid OUT RAW);
TBD
Overload 2
dbms_aq.dequeue(
queue_name IN VARCHAR2,
dequeue_options IN dbms_aq.dequeue_options_t,
message_properties OUT dbms_aq. message_properties_t,
payload OUT sys.standard.<ADT_1>
msgid OUT RAW);
TBD
Overload 3
dbms_aq.dequeue(
queue_name IN VARCHAR2,
dequeue_options IN dbms_aq.dequeue_options_t,
message_properties OUT dbms_aq.message_properties_t,
payload OUT RAW
msgid OUT RAW);
See AQ Demo 1 Linked At Page Bottom
Overload 4
dbms_aq.dequeue(
queue_name IN
VARCHAR2,
dequeue_options IN sys.dbms_aq.dequeue_options_t,
message_properties OUT sys.dbms_aq.message_properties_t,
payload
OUT JSON,
msgid
OUT RAW);
Dequeues an array of messages from the specified queue
Overload 1
dbms_aq.dequeue_array(
queue_name IN VARCHAR2,
dequeue_options IN dbms_aq.dequeue_options_t,
array_size IN BINARY_INTEGER,
message_properties_array OUT dbms_aq.message_properties_array_t,
payload_array OUT sys.standard.<COLLECTION_1>,
msgid_array OUT dbms_aq.msgid_array_t)
RETURN PLS_INTEGER;
See ENQUEUE_ARRAY Demo Below
Overload 2
dbms_aq.dequeue_array(
queue_name IN VARCHAR2,
dequeue_options IN dbms_aq.dequeue_options_t,
array_size IN BINARY_INTEGER,
message_properties_array OUT dbms_aq.message_properties_array_t,
payload_array OUT sys.standard.<COLLECTION_1>,
msgid_array OUT dbms_aq.msgid_array_t,
error_array OUT dbms_aq.error_array_t)
RETURN PLS_INTEGER;
dbms_aq.enqueue(
queue_name IN VARCHAR2,
enqueue_options IN dbms_aq.enqueue_options_t,
message_properties IN dbms_aq.message_properties_t,
payload IN sys.standard.<OPAQUE_1>,
msgid OUT RAW);
TBD
Overload 2
dbms_aq.enqueue(
queue_name IN VARCHAR2,
enqueue_options IN dbms_aq.enqueue_options_t,
message_properties IN dbms_aq.message_properties_t,
payload IN sys.standard.<ADT_1>,
msgid OUT RAW);
See AQ Demo 1 Linked At Page Bottom
Overload 3
dbms_aq.enqueue(
queue_name IN VARCHAR2,
enqueue_options IN dbms_aq.enqueue_options_t,
message_properties IN dbms_aq.message_properties_t,
payload IN RAW,
msgid OUT RAW);
See AQ Demo 1 Linked At Page Bottom
Overload 4
dbms_aq.enqueue(
queue_name IN
VARCHAR2,
enqueue_options IN sys.dbms_aq.enqueue_options_t,
message_properties IN sys.dbms_aq.message_properties_t,
payload
IN JSON
msgid
OUT RAW);
dbms_aq.enqueue_array(
queue_name IN VARCHAR2,
enqueue_options IN dbms_aq.enqueue_options_t,
array_size IN PLS_INTEGER,
message_properties_array IN dbms_aq.message_properties_array_t,
payload_array IN sys.standard.<COLLECTION_1>,
msgid_array OUT dbms_aq.msgid_array_t)
RETURN PLS_INTEGER;
set serveroutput on
CREATE OR REPLACE TYPE message as OBJECT (
data VARCHAR2(10));
/
CREATE OR REPLACE TYPE message_tbl AS TABLE OF message;
/
FOR i IN 1..retval
LOOP
dbms_output.put_line ('Message ' || i || ' payload: ' || payloadarr(i).data);
END LOOP;
END;
/
DECLARE
app1 sys.aq$_agent;
BEGIN
app1 := sys.aq$_agent('sub1', NULL, NULL);
dbms_aqadm.remove_subscriber('uw_q',app1);
dbms_aqadm.stop_queue( queue_name => 'uw_q');
dbms_aqadm.drop_queue_table('uw_q_tab', TRUE);
EXECUTE IMMEDIATE 'DROP TYPE message_tbl';
EXECUTE IMMEDIATE 'DROP TYPE message';
END;
/
Overload 2
dbms_aq.enqueue_array(
queue_name IN VARCHAR2,
enqueue_options IN dbms_aq.enqueue_options_t,
array_size IN PLS_INTEGER,
message_properties_array IN dbms_aq.message_properties_array_t,
payload_array IN sys.standard.<COLLECTION_1>,
msgid_array OUT dbms_aq.msgid_array_t,
error_array OUT dbms_aq.error_array_t)
RETURN PLS_INTEGER;
dbms_aq.enqueue_int_shard(
qname IN VARCHAR2,
visibility IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER,
priority IN BINARY_INTEGER,
delay IN BINARY_INTEGER,
expiration IN BINARY_INTEGER,
correlation IN VARCHAR2,
exception_queue IN VARCHAR2,
delivery_time IN TIMESTAMP WITH TIME ZONE,
old_msgid IN RAW,
payload IN RAW,
msgid IN RAW,
enq_time IN TIMESTAMP WITH TIME ZONE,
versionflg IN BINARY_INTEGER,
delay_shard IN BINARY_INTEGER);
TBD
Overload 2
dbms_aq.enqueue_int_shard(
qname IN VARCHAR2,
visibility IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER,
priority IN BINARY_INTEGER,
delay IN BINARY_INTEGER,
expiration IN BINARY_INTEGER,
correlation IN VARCHAR2,
exception_queue IN VARCHAR2,
delivery_time IN TIMESTAMP WITH TIME ZONE,
old_msgid IN RAW,
payload IN BLOB,
msgid IN RAW,
enq_time IN TIMESTAMP WITH TIME ZONE,
versionflg IN BINARY_INTEGER,
delay_shard IN BINARY_INTEGER);
TBD
Overload 3
dbms_aq.enqueue_int_shard(
qname IN VARCHAR2,
visibility IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER,
priority IN BINARY_INTEGER,
delay IN BINARY_INTEGER,
expiration IN BINARY_INTEGER,
correlation IN VARCHAR2,
exception_queue IN VARCHAR2,
delivery_time IN TIMESTAMP WITH TIME ZONE,
old_msgid IN RAW,
payload IN
sys.standard.<ADT_1>,
msgid IN RAW,
enq_time IN TIMESTAMP WITH TIME ZONE,
versionflg IN BINARY_INTEGER,
delay_shard IN BINARY_INTEGER);
dbms_aq.enqueue_int_shard_jms(
qname IN VARCHAR2,
visibility IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER,
priority IN BINARY_INTEGER,
delay IN BINARY_INTEGER,
expiration IN BINARY_INTEGER,
correlation IN VARCHAR2,
exception_queue IN VARCHAR2,
delivery_time IN TIMESTAMP WITH TIME ZONE,
old_msgid IN RAW,
jms_type IN BINARY_INTEGER,
header_property IN VARCHAR2,
user_property_text IN VARCHAR2,
user_property_clob IN CLOB,
payload_RAW IN RAW,
payload_BLOB IN BLOB,
msgid IN RAW,
enq_time IN TIMESTAMP WITH TIME ZONE,
versionflg IN BINARY_INTEGER,
delay_shard IN BINARY_INTEGER);
dbms_aq.enqueue_int_unsharded(
qname IN VARCHAR2,
visibility IN BINARY_INTEGER,
relative_msgid IN RAW,
seq_deviation IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER,
priority IN BINARY_INTEGER,
delay IN BINARY_INTEGER,
expiration IN BINARY_INTEGER,
correlation IN VARCHAR2,
exception_queue IN VARCHAR2,
sender_name IN VARCHAR2,
sender_address IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_msgid IN RAW,
user_property IN sys.anydata,
payload IN sys.standard.<OPAQUE_1>,
recipients IN sys.AQ$_recipients,
msgid IN RAW,
enq_time IN TIMESTAMP,
enq_uid IN VARCHAR2,
step_no IN
BINARY_INTEGER);
TBD
Overload 2
dbms_aq.enqueue_int_unsharded(
qname IN VARCHAR2,
visibility IN BINARY_INTEGER,
relative_msgid IN RAW,
seq_deviation IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER,
priority IN BINARY_INTEGER,
delay IN BINARY_INTEGER,
expiration IN BINARY_INTEGER,
correlation IN VARCHAR2,
exception_queue IN VARCHAR2,
sender_name IN VARCHAR2,
sender_address IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_msgid IN RAW,
user_property IN sys.anydata,
payload IN sys.standard.<ADT_1>,
recipients IN VARRAY SYS aq$_recipients,
msgid IN RAW,
enq_time IN TIMESTAMP,
enq_uid IN VARCHAR2,
step_no IN BINARY_INTEGER);
TBD
Overload 3
dbms_aq.enqueue_int_unsharded(
qname IN VARCHAR2,
visibility IN BINARY_INTEGER,
relative_msgid IN RAW,
seq_deviation IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER,
priority IN BINARY_INTEGER,
delay IN BINARY_INTEGER,
expiration IN BINARY_INTEGER,
correlation IN VARCHAR2,
exception_queue IN VARCHAR2,
sender_name IN VARCHAR2,
sender_address IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_msgid IN RAW,
user_property IN sys.anydata,
payload IN RAW,
recipients IN sys.aq$_recipients,
msgid IN RAW,
enq_time IN TIMESTAMP,
enq_uid IN VARCHAR2,
step_no IN BINARY_INTEGER);
TBD
Overload 4
dbms_aq.enqueue_int_unsharded(
qname IN VARCHAR2,
visibility IN BINARY_INTEGER,
relative_msgid IN RAW,
seq_deviation IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER,
priority IN BINARY_INTEGER,
delay IN BINARY_INTEGER,
expiration IN BINARY_INTEGER,
correlation IN VARCHAR2,
exception_queue IN VARCHAR2,
sender_name IN VARCHAR2,
sender_address IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_msgid IN RAW,
user_property IN sys.anydata,
payload IN BLOB,
recipients IN sys.aq$recipients,
msgid IN RAW,
enq_time IN TIMESTAMP,
enq_uid IN VARCHAR2,
step_no IN BINARY_INTEGER);
Listens on one or more queues on behalf of a list of agents
Overload 1
dbms_aq.listen(
agent_list IN dbms_aq.aq$_agent_list_t,
wait IN BINARY_INTEGER DEFAULT dbms_aq.forever,
agent OUT sys.aq$_agent);
See AQ Demo 1 Linked At Page Bottom
Overload 2
dbms_aq.listen(
agent_list IN dbms_aq.aq$_agent_list_t,
wait IN BINARY_INTEGER DEFAULT dbms_aq.forever,
listen_delivery_mode IN PLS_INTEGER DEFAULT dbms_aq.persistent,
agent OUT sys.aq$_agent,
message_delivery_mode OUT PLS_INTEGER);
Registers an email address, user-defined PL/SQL procedure, or HTTP URL for message notification
dbms_aq.register(reg_list IN sys.aq$_reg_info_list, reg_count IN NUMBER);
DECLARE
reginfo1 sys.aq$_reg_info;
reginfo2 sys.aq$_reg_info;
reginfo3 sys.aq$_reg_info;
reginfo4 sys.aq$_reg_info;
reginfo5 sys.aq$_reg_info;
reginfo6 sys.aq$_reg_info;
reginfolist sys.aq$_reg_info_list;
BEGIN
-- register for p raw q default pres
reginfo1 := sys.aq$_reg_info('PUBSUB1.EVENTS:ADMIN', 1,
'plsql://plsqlregproc1',HEXTORAW('FF'));
-- register for p raw q xml pres
reginfo2 := sys.aq$_reg_info('PUBSUB1.EVENTS:ADMIN', 1,
'plsql://plsqlregproc1?PR=1',HEXTORAW('FF'));
-- register for p ADT q default pres
reginfo3 := sys.aq$_reg_info('PUBSUB1.ADTEVENTS:ADMIN', 1,
'plsql://plsqlregproc2',HEXTORAW('FF'));
-- register for p ADT q xml pres
reginfo4 := sys.aq$_reg_info('PUBSUB1.ADTEVENTS:ADMIN', 1,
'plsql://plsqlregproc2?PR=1',HEXTORAW('FF'));
-- for np q raw and adt can be enqueued into the same queue
-- register for np raw and ADT q default pres
reginfo5 := sys.aq$_reg_info('PUBSUB1.NONPEREVENTS:ADMIN', 1,
'plsql://plsqlregproc1',HEXTORAW('FF'));
-- register for np raw and ADT q xml pres
reginfo6 := sys.aq$_reg_info('PUBSUB1.NONPEREVENTS:ADMIN', 1,
'plsql://plsqlregproc2?PR=1',HEXTORAW('FF'));
dbms_aq.registration_replication(
opcode IN BINARY_INTEGER,
regid IN NUMBER,
subname IN VARCHAR2,
location IN VARCHAR2,
usr IN VARCHAR2,
uctx IN RAW,
ns IN BINARY_INTEGER,
prest IN BINARY_INTEGER,
version IN BINARY_INTEGER,
status IN BINARY_INTEGER,
uctxtype IN BINARY_INTEGER,
qosflgs IN BINARY_INTEGER,
paycbk IN VARCHAR2,
timeout IN BINARY_INTEGER,
regtime IN TIMESTAMP WITH TIME ZONE,
ntfngrpclass IN BINARY_INTEGER,
ntfngrpvalue IN BINARY_INTEGER,
ntfngrptype IN BINARY_INTEGER,
ntfngrpstarttime IN TIMESTAMP WITH TIME ZONE,
ntfngrprepeatcount IN BINARY_INTEGER,
grpnfy IN BINARY_INTEGER,
osesskey IN RAW);
dbms_aq.seek(
queue_name IN VARCHAR2,
consumer_name IN VARCHAR2,
seek_input_array IN dbms_aq.seek_input_array_t,
skip_option IN BINARY_INTEGER,
redequeue_all IN BOOLEAN,
seek_output_array OUT dbms_aq.seek_output_array_t);
Unregisters a subscription which turns off notifications
dbms_aq.unregister(
reg_list IN sys.aq$_reg_info_list,
reg_count IN NUMBER);
DECLARE
reginfo1 sys.aq$_reg_info;
reginfo2 sys.aq$_reg_info;
reginfo3 sys.aq$_reg_info;
reginfo4 sys.aq$_reg_info;
reginfo5 sys.aq$_reg_info;
reginfo6 sys.aq$_reg_info;
reginfolist sys.aq$_reg_info_list;
BEGIN
-- register for p raw q default pres
reginfo1 := sys.aq$_reg_info('PUBSUB1.EVENTS:ADMIN', 1,
'plsql://plsqlregproc1',HEXTORAW('FF'));
-- register for p raw q xml pres
reginfo2 := sys.aq$_reg_info('PUBSUB1.EVENTS:ADMIN', 1,
'plsql://plsqlregproc1?PR=1',HEXTORAW('FF'));
-- register for p ADT q default pres
reginfo3 := sys.aq$_reg_info('PUBSUB1.ADTEVENTS:ADMIN', 1,
'plsql://plsqlregproc2',HEXTORAW('FF'));
-- register for p ADT q xml pres
reginfo4 := sys.aq$_reg_info('PUBSUB1.ADTEVENTS:ADMIN', 1,
'plsql://plsqlregproc2?PR=1',HEXTORAW('FF'));
-- for np q raw and ADT can be enqueued into the same queue
-- register for np raw and adt q default pres
reginfo5 := sys.aq$_reg_info('PUBSUB1.NONPEREVENTS:ADMIN', 1,
'plsql://plsqlregproc1',HEXTORAW('FF'));
-- register for np raw and ADT q xml pres
reginfo6 := sys.aq$_reg_info('PUBSUB1.NONPEREVENTS:ADMIN', 1,
'plsql://plsqlregproc2?PR=1',HEXTORAW('FF'));