Oracle DBMS_AQJMS_INTERNAL
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 Advanced Queuing Java Messaging Service Internal Utilities
AUTHID DEFINER
Dependencies
ALL_TYPES AQ$_JMS_OBJECT_MESSAGE DBMS_AQADM
AQ$_AGENT AQ$_JMS_OBJECT_MESSAGES DBMS_AQADM_SYS
AQ$_JMS_ARRAY_ERRORS AQ$_JMS_STREAM_MESSAGE DBMS_AQINT_LIB
AQ$_JMS_ARRAY_MSGIDS AQ$_JMS_STREAM_MESSAGES DBMS_AQJMS
AQ$_JMS_BYTES_MESSAGE AQ$_JMS_TEXT_MESSAGE DBMS_AQ_LIB
AQ$_JMS_BYTES_MESSAGES AQ$_JMS_TEXT_MESSAGES DBMS_ASSERT
AQ$_JMS_HEADER AQ$_JMS_USERPROPARRAY DBMS_LOB
AQ$_JMS_MAP_MESSAGE AQ$_JMS_USERPROPERTY DBMS_SYS_ERROR
AQ$_JMS_MAP_MESSAGES AQ$_PROPAGATION_STATUS PLITBLM
AQ$_JMS_MESSAGE AQ$_SIG_PROP TRANSFORMATIONS$
AQ$_JMS_MESSAGES DBA_QUEUES USER$
AQ$_JMS_MESSAGE_PROPERTIES DBMS_AQ UTL_RAW
Documented No
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
{ORACLE_HOME}/rdbms/admin/prvtaqjm.plb
Subprograms
 
AQ$_GET_PROP_STAT
Undocumented dbms_aqjms_internal.aq$_get_prop_stat(
qid             IN NUMBER,
db_link         IN  VARCHAR2,
sequence_number OUT BINARY_INTEGER);
TBD
 
AQ$_GET_TRANS_TYPE
Undocumented dbms_aqjms_internal.aq$_get_trans_type(
trans_schema IN  VARCHAR2,
trans_name   IN  VARCHAR2,
src_type     OUT VARCHAR2,
dest_type    OUT VARCHAR2);
TBD
 
AQ$_JMS_DEQUEUE_BYTES_MESSAGES
Undocumented dbms_aqjms_internal.aq$_jms_dequeue_bytes_messages(
queue_name     IN  VARCHAR2,
num_messages   IN  BINARY_INTEGER,
consumer_name  IN  VARCHAR2,
dequeue_mode   IN  BINARY_INTEGER,
navigation     IN  BINARY_INTEGER,
visibility     IN  BINARY_INTEGER,
wait           IN  BINARY_INTEGER,
correlation    IN  VARCHAR2,
deq_condition  IN  VARCHAR2,
signature      IN  sys.aq$_sig_prop,
transformation IN  VARCHAR2,
message_props  OUT sys.aq$_jms_message_properties,
messages       OUT sys.aq$_jms_bytes_messages,
msgids         OUT sys.aq$_jms_array_msgids,
num_dequeued   OUT BINARY_INTEGER);
TBD
 
AQ$_JMS_DEQUEUE_MAP_MESSAGES
Undocumented dbms_aqjms_internal.aq$_jms_dequeue_map_messages(
queue_name     IN  VARCHAR2,
num_messages   IN  BINARY_INTEGER,
consumer_name  IN  VARCHAR2,
dequeue_mode   IN  BINARY_INTEGER,
navigation     IN  BINARY_INTEGER,
visibility     IN  BINARY_INTEGER,
wait           IN  BINARY_INTEGER,
correlation    IN  VARCHAR2,
deq_condition  IN  VARCHAR2,
signature      IN  sys.aq$_sig_prop,
transformation IN  VARCHAR2,
message_props  OUT sys.aq$_jms_message_properties,
messages       OUT sys.aq$_jms_map_messages,
msgids         OUT sys.aq$_jms_array_msgids,
num_dequeued   OUT BINARY_INTEGER);
TBD
 
AQ$_JMS_DEQUEUE_MESSAGES
Undocumented dbms_aqjms_internal.aq$_jms_dequeue_messages(
queue_name     IN  VARCHAR2,
num_messages   IN  BINARY_INTEGER,
consumer_name  IN  VARCHAR2,
dequeue_mode   IN  BINARY_INTEGER,
navigation     IN  BINARY_INTEGER,
visibility     IN  BINARY_INTEGER,
wait           IN  BINARY_INTEGER,
correlation    IN  VARCHAR2,
deq_condition  IN  VARCHAR2,
signature      IN  sys.aq$_sig_prop,
transformation IN  VARCHAR2,
message_props  OUT sys.aq$_jms_message_properties,
messages       OUT sys.aq$_jms_messages,
msgids         OUT sys.aq$_jms_array_msgids,
num_dequeued   OUT BINARY_INTEGER);
TBD
 
AQ$_JMS_DEQUEUE_OBJ_MESSAGES
Undocumented dbms_aqjms_internal.aq$_jms_dequeue_obj_messages(
queue_name     IN  VARCHAR2,
num_messages   IN  BINARY_INTEGER,
consumer_name  IN  VARCHAR2,
dequeue_mode   IN  BINARY_INTEGER,
navigation     IN  BINARY_INTEGER,
visibility     IN  BINARY_INTEGER,
wait           IN  BINARY_INTEGER,
correlation    IN  VARCHAR2,
deq_condition  IN  VARCHAR2,
signature      IN  sys.aq$_sig_prop,
transformation IN  VARCHAR2,
message_props  OUT sys.aq$_jms_message_properties,
messages       OUT sys.aq$_jms_object_messages,
msgids         OUT sys.aq$_jms_array_msgids,
num_dequeued   OUT BINARY_INTEGER,
TBD
 
AQ$_JMS_DEQUEUE_STR_MESSAGES
Undocumented dbms_aqjms_internal.aq$_jms_dequeue_str_messages(
queue_name     IN  VARCHAR2,
num_messages   IN  BINARY_INTEGER,
consumer_name  IN  VARCHAR2,
dequeue_mode   IN  BINARY_INTEGER,
navigation     IN  BINARY_INTEGER,
visibility     IN  BINARY_INTEGER,
wait           IN  BINARY_INTEGER,
correlation    IN  VARCHAR2,
deq_condition  IN  VARCHAR2,
signature      IN  sys.aq$_sig_prop,
transformation IN  VARCHAR2,
message_props  OUT sys.aq$_jms_message_properties,
messages       OUT sys.aq$_jms_stream_messages,
msgids         OUT sys.aq$_jms_array_msgids,
num_dequeued   OUT BINARY_INTEGER);
TBD
 
AQ$_JMS_DEQUEUE_TEXT_MESSAGES
Undocumented dbms_aqjms_internal.aq$_jms_dequeue_text_messages(
queue_name     IN  VARCHAR2,
num_messages   IN  BINARY_INTEGER,
consumer_name  IN  VARCHAR2,
dequeue_mode   IN  BINARY_INTEGER,
navigation     IN  BINARY_INTEGER,
visibility     IN  BINARY_INTEGER,
wait           IN  BINARY_INTEGER,
correlation    IN  VARCHAR2,
deq_condition  IN  VARCHAR2,
signature      IN  sys.aq$_sig_prop,
transformation IN  VARCHAR2,
message_props  OUT sys.aq$_jms_message_properties,
messages       OUT sys.aq$_jms_text_messages,
msgids         OUT sys.aq$_jms_array_msgids,
num_dequeued   OUT BINARY_INTEGER);
TBD
 
AQ$_JMS_ENQUEUE_BYTES_MESSAGES
Undocumented dbms_aqjms_internal.aq$_jms_enqueue_bytes_messages(
queue_name         IN  VARCHAR2,
messages           IN  sys.aq$_jms_bytes_messages,
num_messages       IN  BINARY_INTEGER,
message_props      IN  sys.aq$_jms_message_properties,
visibility         IN  BINARY_INTEGER,
relative_msgid     IN  RAW,
sequence_deviation IN  BINARY_INTEGER,
transformation     IN  VARCHAR2,
msgids             OUT sys.aq$_jms_array_msgids,
errors             OUT sys.aq$_jms_array_errors,
num_enqueued       OUT BINARY_INTEGER);
TBD
 
AQ$_JMS_ENQUEUE_MAP_MESSAGES
Undocumented dbms_aqjms_internal.aq$_jms_enqueue_map_messages(
queue_name         IN  VARCHAR2,
messages           IN  sys.aq$_jms_map_messages,
num_messages       IN  BINARY_INTEGER,
message_props      IN  sys.aq$_jms_message_properties,
visibility         IN  BINARY_INTEGER,
relative_msgid     IN  RAW,
sequence_deviation IN  BINARY_INTEGER,
transformation     IN  VARCHAR2,
msgids             OUT sys.aq$_jms_array_msgids,
errors             OUT sys.aq$_jms_array_errors,
num_enqueued       OUT BINARY_INTEGER);
TBD
 
AQ$_JMS_ENQUEUE_MESSAGES
Undocumented dbms_aqjms_internal.aq$_jms_enqueue_messages(
queue_name         IN  VARCHAR2,
messages           IN  sys.aq$_jms_messages,
num_messages       IN  BINARY_INTEGER,
message_props      IN  sys.aq$_jms_message_properties,
visibility         IN  BINARY_INTEGER,
relative_msgid     IN  RAW,
sequence_deviation IN  BINARY_INTEGER,
transformation     IN  VARCHAR2,
msgids             OUT sys.aq$_jms_array_msgids,
errors             OUT sys.aq$_jms_array_errors,
num_enqueued       OUT BINARY_INTEGER);
TBD
 
AQ$_JMS_ENQUEUE_OBJ_MESSAGES
Undocumented dbms_aqjms_internal.aq$_jms_enqueue_obj_messages(
queue_name         IN  VARCHAR2,
messages           IN  sys.aq$_jms_object_messages,
num_messages       IN  BINARY_INTEGER,
message_props      IN  sys.aq$_jms_message_properties,
visibility         IN  BINARY_INTEGER,
relative_msgid     IN  RAW,
sequence_deviation IN  BINARY_INTEGER,
transformation     IN  VARCHAR2,
msgids             OUT sys.aq$_jms_array_msgids,
errors             OUT sys.aq$_jms_array_errors,
num_enqueued       OUT BINARY_INTEGER);
TBD
 
AQ$_JMS_ENQUEUE_STR_MESSAGES
Undocumented dbms_aqjms_internal.aq$_jms_enqueue_str_messages(
queue_name         IN  VARCHAR2,
messages           IN  sys.aq$_jms_stream_messages,
num_messages       IN  BINARY_INTEGER,
message_props      IN  sys.aq$_jms_message_properties,
visibility         IN  BINARY_INTEGER,
relative_msgid     IN  RAW,
sequence_deviation IN  BINARY_INTEGER,
transformation     IN  VARCHAR2,
msgids             OUT sys.aq$_jms_array_msgids,
errors             OUT sys.aq$_jms_array_errors,
num_enqueued       OUT BINARY_INTEGER);
TBD
 
AQ$_JMS_ENQUEUE_TEXT_MESSAGES
Undocumented dbms_aqjms_internal.aq$_jms_enqueue_text_messages(
queue_name         IN  VARCHAR2,
messages           IN  sys.aq$_jms_text_messages,
num_messages       IN  BINARY_INTEGER,
message_props      IN  sys.aq$_jms_message_properties,
visibility         IN  BINARY_INTEGER,
relative_msgid     IN  RAW,
sequence_deviation IN  BINARY_INTEGER,
transformation     IN  VARCHAR2,
msgids             OUT sys.aq$_jms_array_msgids
errors             OUT sys.aq$_jms_array_errors
num_enqueued       OUT BINARY_INTEGER);
TBD
 
AQ$_PURGE_MESSAGE
Undocumented dbms_aqjms_internal.aq$purge_message(
q_schema IN VARCHAR2,
q_name   IN VARCHAR2,
username IN VARCHAR2,
msg_id   IN RAW);
TBD
 
AQ$_UPDATE_PROP_STAT
Undocumented dbms_aqjms_internal.aq$update_prop_stat(
qid             IN NUMBER,
db_link         IN VARCHAR2,
sequence_number IN BINARY_INTEGER,
status_code     IN BINARY_INTEGER);
TBD
 
CREATE_BYTES_MESSAGE
Undocumented dbms_aqjms_internal.create_bytes_message(
payload      OUT sys.aq$_jms_bytes_message,
byte_plod    IN  BLOB,
jms_header   IN  VARCHAR2,
jms_userprop IN  CLOB);
TBD
 
CREATE_GENERIC_MESSAGE
Undocumented dbms_aqjms_internal.create_generic_message(
payload      OUT sys.aq$_jms_message,
byte_plod    IN  BLOB,
jms_header   IN  VARCHAR2,
jms_userprop IN  CLOB,
jms_msg_type IN  NUMBER);
TBD
 
CREATE_MAP_MESSAGE
Undocumented dbms_aqjms_internal.create_map_message(
payload      OUT sys.aq$_jms_map_message,
byte_plod    IN  BLOB,
jms_header   IN  VARCHAR2,
jms_userprop IN  CLOB);
TBD
 
CREATE_OBJECT_MESSAGE
Undocumented dbms_aqjms_internal.create_object_message(
payload      OUT sys.aq$_jms_object_message,
byte_plod    IN  BLOB,
jms_header   IN  VARCHAR2,
jms_userprop IN  CLOB);
TBD
 
CREATE_STREAM_MESSAGE
Undocumented dbms_aqjms_internal.create_stream_message(
payload      OUT sys.aq$_jms_stream_message,
byte_plod    IN  BLOB,
jms_header   IN  VARCHAR2,
jms_userprop IN  CLOB);
TBD
 
CREATE_TEXT_MESSAGE
Undocumented dbms_aqjms_internal.create_text_message(
payload      OUT sys.aq$_jms_text_message,
byte_plod    IN  BLOB,
jms_header   IN  VARCHAR2,
jms_userprop IN  CLOB);
TBD
 
ENQUEUE_BYTES_INTERNAL
Undocumented dbms_aqjms_internal.enqueue_bytes_internal(
payload           IN  sys.aq$_jms_bytes_message,
byte_plod         OUT BLOB,
header_formatted  OUT VARCHAR2,
userprp_formatted OUT CLOB);
TBD
 
ENQUEUE_GENERIC_INTERNAL
Undocumented dbms_aqjms_internal.enqueue_generic_internal(
payload           IN  sys.aq$_jms_message,
byte_plod         OUT BLOB,
header_formatted  OUT VARCHAR2,
userprp_formatted OUT CLOB,
message_type      OUT NUMBER);
TBD
 
ENQUEUE_MAP_INTERNAL
Undocumented dbms_aqjms_internal.enqueue_map_internal(
ayload            IN  sys.aq$_jms_map_message,
byte_plod         OUT BLOB,
header_formatted  OUT VARCHAR2,
userprp_formatted OUT CLOB);
TBD
 
ENQUEUE_OBJECT_INTERNAL
Undocumented dbms_aqjms_internal.enqueue_object_internal(
payload           IN  sys.aq$_jms_object_message,
byte_plod         OUT BLOB,
header_formatted  OUT VARCHAR2,
userprp_formatted OUT CLOB);
TBD
 
ENQUEUE_STREAM_INTERNAL
Undocumented dbms_aqjms_internal.enqueue_stream_internal(
payload           IN  sys.aq$_jms_stream_message,
byte_plod         OUT BLOB,
header_formatted  OUT VARCHAR2,
userprp_formatted OUT CLOB);
TBD
 
ENQUEUE_TEXT_INTERNAL
Undocumented dbms_aqjms_internal.enqueue_text_internal(
payload           IN  sys.aq$_jms_text_message,
byte_plod         OUT BLOB,
header_formatted  OUT VARCHAR2,
userprp_formatted OUT CLOB);
TBD
 
FLATTEN_JMS
Undocumented dbms_aqjms_internal.flatten_jms(
payload_header    IN  sys.aq$_jms_header,
bytes_len         IN  NUMBER,
bytes_raw         IN  RAW,
bytes_lob         IN  BLOB,
text_len          IN  NUMBER,
text_var          IN  VARCHAR2,
text_lob          IN  CLOB,
byte_plod         OUT BLOB,
header_formatted  OUT VARCHAR2,
userprp_formatted OUT CLOB);
TBD
 
GET_DB_USERNAME_FOR_AGENT
Undocumented dbms_aqjms_internal.get_db_username_for_agent(
agent_name    IN  VARCHAR2,
owner_name    IN  VARCHAR2,
queue_name    IN  VARCHAR2,
operation     IN  BINARY_INTEGER,
curr_db_user  IN  VARCHAR2,
invoking_user IN  VARCHAR2,
db_username   OUT VARCHAR2,
enq_priv      OUT BINARY_INTEGER,
deq_priv      OUT BINARY_INTEGER);
TBD

Related Topics
Built-in Functions
Built-in Packages
Database Security
DBMS_AQ
DBMS_AQJMS
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