Oracle DBMS_AQIN
Version 21c

General Information
Library Note Morgan's Library Page Header
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 Provides secure access to Oracle Java Messaging Services (JMS) interfaces.
AUTHID CURRENT_USER
Dependencies
ANYDATA AQ$_JMS_STREAMS_MESSAGE DBMS_AQ
AQ$_AGENT AQ$_JMS_TEXT_MESSAGE DBMS_AQADM
AQ$_DUMMY_T AQ$_RECIPIENTS DBMS_AQADM_SYS
AQ$_JMS_BYTES_MESSAGE AQ$_REG_INFO DBMS_AQ_LIB
AQ$_JMS_MAP_MESSAGE AQ$_REG_INFO_LIST DBMS_STANDARD
AQ$_JMS_MESSAGE AQ$_SIG_PROP PLITBLM
AQ$_JMS_OBJECT_MESSAGE AQ$_SUBSCRIBERS  
Documented Only the security model: Packages and Types Reference
First Available Not Known
Security Model Owned by SYS with EXECUTE granted to the AQ_ADMINISTRATOR_ROLE, AQ_USER_ROLE, and EXECUTE_CATALOG_ROLE roles.
Source {ORACLE_HOME}/rdbms/admin/prvtaqji.plb
Subprograms
 
AQ$_ALTER_QUEUE
Undocumented 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);
TBD
 
AQ$_CREATE_QUEUE
Undocumented 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);
TBD
 
AQ$_CREATE_QUEUE_TABLE
Undocumented 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);
TBD
 
AQ$_DEQUEUE_IN
Undocumented
Overload 1
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>);
TBD
 
AQ$_DEQUEUE_RAW
Undocumented

Overload 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);
TBD
 
AQ$_DROP_QUEUE
Undocumented dbms_aqin.aq$_drop_queue(
queue_name  IN VARCHAR2,
auto_commit IN BINARY_INTEGER);
TBD
 
AQ$_DROP_QUEUE_TABLE
Undocumented dbms_aqin.aq$_drop_queue_table(
queue_table IN VARCHAR2,
FORCE       IN BINARY_INTEGER,
auto_commit IN BINARY_INTEGER);
TBD
 
AQ$_ENQUEUE_OBJ
Undocumented

Overload 1
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);
TBD
 
AQ$_ENQUEUE_OBJ_NO_RECPL
Undocumented
Overload 1
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);
TBD
 
AQ$_ENQUEUE_RAW
Undocumented 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);
TBD
 
AQ$_ENQUEUE_RAW_NO_RECPL
Undocumented 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);
TBD
 
AQ$_GETBLOB_FROM_JMSANYDATA
Returns a ANYDATA data type message as a BLOB dbms_aqin.aq$_getblob_from_jmsanydata(ad IN sys.anydata)
RETURN BLOB;
TBD
 
AQ$_GETCLOB_FROM_JMSANYDATA
Returns a ANYDATA data type message as a CLOB dbms_aqin.aq$_getclob_from_jmsanydata(ad IN sys.anydata)
RETURN CLOB;
TBD
 
AQ$_JMS_ENQUEUE_BYTES_MESSAGE
Undocumented 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);
TBD
 
AQ$_JMS_ENQUEUE_MAP_MESSAGE
Undocumented 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);
TBD
 
AQ$_JMS_ENQUEUE_OBJECT_MESSAGE
Undocumented 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);
TBD
 
AQ$_JMS_ENQUEUE_STREAM_MESSAGE
Undocumented 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);
TBD
 
AQ$_JMS_ENQUEUE_TEXT_MESSAGE
Undocumented 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);
TBD
 
AQ$_LISTEN
Undocumented dbms_aqin.aq$_listen(
AGENT_LIST IN  sys.aq$_recipients,
wait       IN  BINARY_INTEGER,
AGENT      OUT sys.aq$_agent);
TBD
 
AQ$_QUEUE_SUBSCRIBERS
Undocumented dbms_aqin.aq$_queue_subscribers(
queue_name IN  VARCHAR2,
subs_list  OUT sys.aq$_subscribers);
TBD
 
AQ$_REGISTER_IN
Undocumented dbms_aqin.aq$_register_in(
NAME      IN VARCHAR2,
namespace IN NUMBER,
callback  IN VARCHAR2,
context   IN RAW);
TBD
 
AQ$_START_QUEUE
Undocumented dbms_aqin.aq$_start_queue(
queue_name IN VARCHAR2,
enqueue    IN BINARY_INTEGER,
dequeue    IN BINARY_INTEGER);
TBD
 
AQ$_STOP_QUEUE
Undocumented dbms_aqin.aq$_stop_queue(
queue_name IN VARCHAR2,
enqueue    IN BINARY_INTEGER,
dequeue    IN BINARY_INTEGER,
wait       IN BINARY_INTEGER);
TBD
 
GET_DEQ_SORT
Returns the dequeue sort value dbms_aqin.get_deq_sort RETURN BOOLEAN;
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;
/
 
GET_MULTI_RETRY
Returns the multi-retry value dbms_aqin.get_multi_retry RETURN BOOLEAN;
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;
/
 
SET_DEQ_SORT
If TRUE enables dequeue sorting dbms_aqin.set_deq_sort(state IN BOOLEAN);
exec dbms_aqin.set_deq_sort(TRUE);
 
SET_MULTI_RETRY
If TRUE enables multi retry dbms_aqin.set_multi_retry(state IN BOOLEAN);
exec dbms_aqin.set_multi_retry(TRUE);

Related Topics
Built-in Functions
Built-in Packages
DBMS_AQ
DBMS_AQADM
DBMS_AQADM_INV
DBMS_AQADM_VAR
DBMS_AQELM
DBMS_AQ_BQVIEW
DBMS_AQ_EXP_CMT_TIME_TABLES
DBMS_AQ_EXP_DEQUEUELOG_TABLES
DBMS_AQ_EXP_HISTORY_TABLES
DBMS_AQ_EXP_INDEX_TABLES
DBMS_AQ_EXP_TIMEMGR_TABLES
DBMS_AQ_EXP_ZECURITY
DBMS_AQ_IMP_ZECURITY
What's New In 21c
What's New In 23c

Morgan's Library Page Footer
This site is maintained by Dan Morgan. Last Updated: This site is protected by copyright and trademark laws under U.S. and International law. © 1998-2023 Daniel A. Morgan All Rights Reserved
  DBSecWorx