Owned by SYS with EXECUTE granted to the AQ_ADMINISTRATOR_ROLE, AQ_USER_ROLE, EXECUTE_CATALOG_ROLE, OGG_APPLY, OGG_CAPTURE,
OGG_SHARED_CAPTURE, XSTREAM_APPLY and XSTREAM_CAPTURE roles.
dbms_aqin.aq$_alter_queue(
queue_name IN VARCHAR2,
max_retries IN NUMBER,
retry_delay IN NUMBER,
retention_time IN NUMBER,
auto_commit IN BINARY_INTEGER);
dbms_aqin.aq$_create_queue(
queue_name IN VARCHAR2,
queue_table IN VARCHAR2,
queue_type IN BINARY_INTEGER,
max_retries IN NUMBER,
retry_delay IN NUMBER,
retention_time IN NUMBER,
dependency_tracking IN BINARY_INTEGER,
comment IN VARCHAR2,
auto_commit IN BINARY_INTEGER);
dbms_aqin.aq$_create_queue_table(
queue_table IN VARCHAR2,
queue_payload_type IN VARCHAR2,
storage_clause IN VARCHAR2,
sort_list IN VARCHAR2,
multiple_consumers IN BINARY_INTEGER,
message_grouping IN BINARY_INTEGER,
comment IN VARCHAR2,
auto_commit IN BINARY_INTEGER,
primary_instance IN BINARY_INTEGER,
secondary_instance IN BINARY_INTEGER,
compatible IN VARCHAR2);
dbms_aqin.aq$_dequeue_in(
queue_name IN VARCHAR2,
subscriber IN VARCHAR2,
msgid IN RAW,
correlation IN VARCHAR2,
dequeue_mode IN BINARY_INTEGER,
navigation 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 sys.aq$_recipients,
sender_name OUT VARCHAR2,
sender_addr OUT VARCHAR2,
sender_protocol OUT BINARY_INTEGER,
original_msgid OUT RAW,
payload_type IN BINARY_INTEGER,
raw_user_data OUT RAW,
object_user_data OUT sys.standard<ADT_1>,
deq_cond IN VARCHAR2,
signature IN sys.aq$_sig_prop,
out_sign OUT sys.aq$_sig_prop,
transformation IN VARCHAR2);
TBD
Overload 2
dbms_aqin.aq$_dequeue_in(
queue_name IN VARCHAR2,
subscriber IN VARCHAR2,
msgid IN RAW,
correlation IN VARCHAR2,
dequeue_mode IN BINARY_INTEGER,
navigation 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 sys.aq$_recipients,
sender_name OUT VARCHAR2,
sender_addr OUT VARCHAR2,
sender_protocol OUT BINARY_INTEGER,
original_msgid OUT RAW,
payload_type IN BINARY_INTEGER,
raw_user_data OUT RAW,
object_user_data OUT sys.standard<ADT_1>,
deq_cond IN VARCHAR2,
signature IN sys.aq$_sig_prop,
out_sign OUT sys.aq$_sig_prop,
transformation IN VARCHAR2,
delivery_mode IN BINARY_INTEGER,
OUT_delivery_mode OUT BINARY_INTEGER);
TBD
Overload 3
dbms_aqin.aq$_dequeue_in(
queue_name IN VARCHAR2,
subscriber IN VARCHAR2,
msgid IN RAW,
correlation IN VARCHAR2,
dequeue_mode IN BINARY_INTEGER,
navigation 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 sys.aq$_recipients,
sender_name OUT VARCHAR2,
sender_addr OUT VARCHAR2,
sender_protocol OUT BINARY_INTEGER,
original_msgid OUT RAW,
payload_type IN BINARY_INTEGER,
raw_user_data OUT RAW,
object_user_data OUT sys.standard<OPAQUE_1>,
deq_cond IN VARCHAR2,
signature IN sys.aq$_sig_prop,
out_sign OUT sys.aq$_sig_prop,
transformation IN VARCHAR2);
TBD
Overload 4
queue_name IN VARCHAR2,
subscriber IN VARCHAR2,
msgid IN RAW,
correlation IN VARCHAR2,
dequeue_mode IN BINARY_INTEGER,
navigation 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 sys.aq$_recipients,
sender_name OUT VARCHAR2,
sender_addr OUT VARCHAR2,
sender_protocol OUT BINARY_INTEGER,
original_msgid OUT RAW,
payload_type IN BINARY_INTEGER,
raw_user_data OUT RAW,
object_user_data OUT sys.standard<OPAQUE_1>,
deq_cond IN VARCHAR2,
signature IN sys.aq$_sig_prop,
out_sign OUT sys.aq$_sig_prop,
transformation IN VARCHAR2,
delivery_mode IN BINARY_INTEGER,
OUT_delivery_mode OUT BINARY_INTEGER);
TBD
Overload 5
dbms_aqin.aq$_dequeue_in(
queue_name IN VARCHAR2,
subscriber IN VARCHAR2,
msgid IN RAW,
correlation IN VARCHAR2,
dequeue_mode IN BINARY_INTEGER,
navigation 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 sys.aq$_recipients,
sender_name OUT VARCHAR2,
sender_addr OUT VARCHAR2,
sender_protocol OUT BINARY_INTEGER,
original_msgid OUT RAW,
payload_type IN BINARY_INTEGER,
raw_user_data OUT RAW,
object_user_data OUT sys.standard<ADT_1>);
dbms_aqin.aq$_dequeue_raw(
queue_name IN VARCHAR2,
SUBSCRIBER IN VARCHAR2,
msgid IN RAW,
correlation IN VARCHAR2,
dequeue_mode IN BINARY_INTEGER,
navigation 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 sys.aq$_recipients,
sender_name OUT VARCHAR2,
sender_addr OUT VARCHAR2,
sender_protocol OUT BINARY_INTEGER,
original_msgid OUT RAW,
payload_type IN BINARY_INTEGER,
raw_user_data OUT RAW,
deq_cond IN VARCHAR2,
signature IN sys.aq$_sig_prop,
out_sign OUT sys.aq$_sig_prop,
transformation IN VARCHAR2);
TBD
Overload 2
dbms_aqin.aq$_dequeue_raw(
queue_name IN VARCHAR2,
SUBSCRIBER IN VARCHAR2,
msgid IN RAW,
correlation IN VARCHAR2,
dequeue_mode IN BINARY_INTEGER,
navigation 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 sys.aq$_recipients,
sender_name OUT VARCHAR2,
sender_addr OUT VARCHAR2,
sender_protocol OUT BINARY_INTEGER,
original_msgid OUT RAW,
payload_type IN BINARY_INTEGER,
raw_user_data OUT RAW,
deq_cond IN VARCHAR2,
signature IN sys.aq$_sig_prop,
out_sign OUT sys.aq$_sig_prop,
transformation IN VARCHAR2,
delivery_mode IN BINARY_INTEGER,
OUT_delivery_mode OUT BINARY_INTEGER);
dbms_aqin.aq$_enqueue_obj(
queue_name IN VARCHAR2,
sender_name IN VARCHAR2,
sender_addr IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_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,
payload_type IN BINARY_INTEGER,
raw_user_data IN RAW,
OBJECT_USER_DATA IN sys.standard<ADT_1>,
recipients IN sys.aq$_recipients,
msgid OUT RAW,
signature IN sys.aq$_sig_prop,
transformation IN VARCHAR2,
delivery_mode IN BINARY_INTEGER);
TBD
Overload 2
dbms_aqin.aq$_enqueue_obj(
queue_name IN VARCHAR2,
sender_name IN VARCHAR2,
sender_addr IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_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,
payload_type IN BINARY_INTEGER,
raw_user_data IN RAW,
OBJECT_USER_DATA IN sys.standard<OPAQUE_1>
recipients IN sys.aq$_recipients,
msgid OUT RAW,
signature IN sys.aq$_sig_prop,
transformation IN VARCHAR2
delivery_mode IN BINARY_INTEGER);
dbms_aqin.aq$_enqueue_obj_no_recpl(
queue_name IN VARCHAR2,
sender_name IN VARCHAR2,
sender_addr IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_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,
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,
delivery_mode IN BINARY_INTEGER);
TBD
Overload 2
dbms_aqin.aq$_enqueue_obj_no_recpl(
queue_name IN VARCHAR2,
sender_name IN VARCHAR2,
sender_addr IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_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,
payload_type IN BINARY_INTEGER,
raw_user_data IN RAW,
OBJECT_USER_DATA IN sys.standard<OPAQUE_1>,
msgid OUT RAW,
signature IN sys.aq$_sig_prop,
transformation IN VARCHAR2
delivery_mode IN BINARY_INTEGER);
dbms_aqin.aq$_enqueue_raw(
queue_name IN VARCHAR2,
sender_name IN VARCHAR2,
sender_addr IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_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,
payload_type IN BINARY_INTEGER,
raw_user_data IN RAW,
OBJECT_USER_DATA IN sys.standard<ADT_1>,
recipients IN sys.aq$_recipients,
msgid OUT RAW,
signature IN sys.aq$_sig_prop,
transformation IN VARCHAR2,
delivery_mode IN BINARY_INTEGER);
dbms_aqin.aq$_enqueue_raw_no_recpl(
queue_name IN VARCHAR2,
sender_name IN VARCHAR2,
sender_addr IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_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,
payload_type IN BINARY_INTEGER,
raw_user_data IN RAW,
msgid OUT RAW,
signature IN sys.aq$_sig_prop,
transformation IN VARCHAR2,
delivery_mode IN BINARY_INTEGER);
dbms_aqin.aq$_enqeue_bytes_message(
queue_name IN VARCHAR2,
sender_name IN VARCHAR2,
sender_addr IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_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,
payload_type IN BINARY_INTEGER,
raw_user_data IN RAW,
bytes_message IN sys.aq$_jms_byte_message,
recipients IN sys.aq$_recipients,
msgid OUT RAW,
gen_payload IN BINARY_INTEGER,
signature IN sys.aq$_sig_prop,
transformation IN VARCHAR2,
create_new_lob IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER);
dbms_aqin.aq$_jms_enqueue_map_message(
queue_name IN VARCHAR2,
sender_name IN VARCHAR2,
sender_addr IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_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,
payload_type IN BINARY_INTEGER,
raw_user_data IN RAW,
map_messae IN sys.aq$_jms_map_message,
recipients IN sys.aq$_recipients,
msgid OUT RAW,
gen_payload IN BINARY_INTEGER,
signature IN sys.aq$_sig_prop,
transformation IN VARCHAR2,
create_new_lob IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER);
dbms_aqin.aq$_jms_enqueue_object_message(
queue_name IN VARCHAR2,
sender_name IN VARCHAR2,
sender_addr IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_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,
payload_type IN BINARY_INTEGER,
raw_user_data IN RAW,
object_message IN sys.aq$_jms_object_message,
recipients IN sys.aq$_recipients,
msgid OUT RAW,
gen_payload IN BINARY_INTEGER,
signature IN sys.aq$_sig_prop,
transformation IN VARCHAR2,
create_new_lob IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER);
dbms_aqin.aq$_jms_enqueue_stream_message(
queue_name IN VARCHAR2,
sender_name IN VARCHAR2,
sender_addr IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_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,
payload_type IN BINARY_INTEGER,
raw_user_data IN RAW,
stream_message IN sys.aq$_jms_stream_message,
recipients IN sys.aq$_recipients,
msgid OUT RAW,
gen_payload IN BINARY_INTEGER,
signature IN sys.aq$_sig_prop,
transformation IN VARCHAR2,
create_new_lob IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER);
dbms_aqin.aq$_jms_enqueue_text_message(
queue_name IN VARCHAR2,
sender_name IN VARCHAR2,
sender_addr IN VARCHAR2,
sender_protocol IN BINARY_INTEGER,
original_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,
payload_type IN BINARY_INTEGER,
raw_user_data IN RAW,
text_message IN sys.aq$_jms_text_message,
recipients IN sys.aq$_recipients,
msgid OUT RAW,
gen_payload IN BINARY_INTEGER,
signature IN sys.aq$_sig_prop,
transformation IN VARCHAR2,
create_new_lob IN BINARY_INTEGER,
delivery_mode IN BINARY_INTEGER);
BEGIN
IF dbms_aqin.get_deq_sort THEN
dbms_output.put_line('Dequeue Sort Enabled');
ELSE
dbms_output.put_line('Dequeue Sort Disabled');
END IF;
END;
/ Dequeue Sort Disabled
BEGIN
IF dbms_aqin.get_multi_retry THEN
dbms_output.put_line('Multi Retry Enabled');
ELSE
dbms_output.put_line('Multi Retry Disabled');
END IF;
END;
/ Multi Retry Disabled