Oracle DBMS_AQJMS
Version 21c

General Information
Library Note Morgan's Library Page Header
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 Java Messaging Service interface
AUTHID CURRENT_USER
Dependencies
ANYDATA AQ$_JMS_OBJECT_MESSAGE DBMS_AQADM_SYSCALLS
AQ$_AGENT AQ$_JMS_OBJECT_MESSAGES DBMS_AQJMS_INTERNAL
AQ$_JMS_ARRAY_ERRORS AQ$_JMS_STREAM_MESSAGE DBMS_AQ_LIB
AQ$_JMS_ARRAY_ERROR_INFO AQ$_JMS_STREAM_MESSAGES DBMS_ASSERT
AQ$_JMS_ARRAY_MSGIDS AQ$_JMS_TEXT_MESSAGE DBMS_LOB
AQ$_JMS_BYTES_MESSAGE AQ$_JMS_TEXT_MESSAGES DBMS_PRIV_CAPTURE
AQ$_JMS_BYTES_MESSAGES AQ$_JMS_USERPROPARRAY DBMS_PRVTAQIS
AQ$_JMS_HEADER AQ$_JMS_USERPROPERTY DBMS_SESSION
AQ$_JMS_MAP_MESSAGE AQ$_SIG_PROP DUAL
AQ$_JMS_MAP_MESSAGES DBA_QUEUES PLITBLM
AQ$_JMS_MESSAGES DBMS_AQ PROPS$
AQ$_JMS_MESSAGE_PROPERTIES DBMS_AQADM_INV USER_QUEUES
AQ$_JMS_MESSAGE_PROPERTY DBMS_AQADM_SYS  
Documented No
First Available Not known
Security Model Owned by SYS with EXECUTE granted to PUBLIC
Source {ORACLE_HOME}/rdbms/admin/prvtaqji.plb
{ORACLE_HOME}/rdbms/admin/prvtaqjm.plb
Subprograms
AQ$_ADD_NONDURABLE_SUBSCRIBER
Undocumented dbms_aqjms.aq$_add_nondurable_subscriber(
queue               IN     VARCHAR2,
rule                IN     VARCHAR2,
transformation      IN     VARCHAR2,
client_session_guid IN OUT VARCHAR2,
subscriber_name        OUT VARCHAR2);
TBD
AQ$_ADD_NONDURABLE_SUB_SQ
Undocumented dbms_aqjms.aq$_add_nondurable_sub_sq(
queue           IN  VARCHAR2,
rule            IN  VARCHAR2,
transformation  IN  VARCHAR2,
subscriber_name OUT VARCHAR2);
TBD
 
AQ$_ADD_SUBSCRIBER
Undocumented dbms_aqjms.aq$_add_subscriber(
queue          IN VARCHAR2,
subscriber     IN sys.aq$agent,
rule           IN VARCHAR2,
transformation IN VARCHAR2,
secure_q       IN BINARY_INTEGER,
delivery_mode  IN BINARY_INTEGER,
queue_to_queue IN BOOLEAN);
TBD
 
AQ$_ALTER_SUBSCRIBER
Undocumented

Overload 1
dbms_aqjms.aq$_alter_subscriber(
queue      IN VARCHAR2,
subscriber IN sys.aq$_agent,
rule       IN VARCHAR2);
TBD
Undocumented

Overload 2
dbms_aqjms.aq$_alter_subscriber(
queue          IN VARCHAR2,
subscriber     IN sys.aq$agent,
rule           IN VARCHAR2,
transformation IN VARCHAR2,
secure_q       IN BINARY_INTEGER);
TBD
 
AQ$_DROPNONDURABLE_SUB_SQ
Undocumented dbms_aqjms.aq$_dropnondurable_sub_sq(
queue           IN VARCHAR2,
subscriber_name IN VARCHAR2);
TBD
 
AQ$_GET_PROP_STAT
Undocumented dbms_aqjms.aq$_get_prop_stat(
q_id            IN  NUMBER,
db_link         IN  VARCHAR2,
sequence_number OUT BINARY_INTEGER);
TBD
 
AQ$_GET_TRANS_TYPE
Undocumented dbms_aqjms.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.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.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.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.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.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.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.aq$_jms_enqueue_bytes_messages(
queue_name         IN  VARCHAR2,
messages           IN  sys.aq$_jms_byte_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.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.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.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.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.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$_PR
Undocumented dbms_aqjms.aq$_pr(ad IN OPAQUE/XMLTYPE, SYS ANYDATA) RETURN sys,aq$_jms_userproparray;
TBD
 
AQ$_PURGE_MESSAGE
Undocumented dbms_aqjms.aq$_purge_message(
queue_name IN VARCHAR2,
msgid      IN RAW);
TBD
 
AQ$_REGISTER
Undocumented dbms_aqjms.aq$_register(
schema       IN VARCHAR2,
subname      IN VARCHAR2,
protocol     IN VARCHAR2,
host         IN VARCHAR2,
port_no      IN VARCHAR2,
presentation IN BINARY_INTEGER,
version      IN BINARY_INTEGER);
TBD
 
AQ$_REMOVE_SUBSCRIBER
Undocumented dbms_aqjms.aq$_remove_subscriber(
queue      IN VARCHAR2,
subscriber IN sys.aq$_agent,
secure_q   IN BINARY_INTEGER);
TBD
 
AQ$_REM_NONDURABLE_SUBSCRIBER
Undocumented dbms_aqjms.aq$_rem_nondurable_subscriber(client_session_guid IN VARCHAR2);
TBD
 
AQ$_UNREGISTER
Undocumented dbms_aqjms.aq$_unregister(
schema   IN VARCHAR2,
subname  IN VARCHAR2,
protocol IN VARCHAR2,
host     IN VARCHAR2,
port_no  IN VARCHAR2);
TBD
 
AQ$_UPDATE_PROP_STAT
Undocumented dbms_aqjms.aq$_update_prop_stat(
q_id            IN NUMBER,
db_link         IN VARCHAR2,
sequence_number IN BINARY_INTEGER,
status_code     IN BINARY_INTEGER);
TBD
 
AQ$_UPDATE_PROP_STAT_QNAME
Undocumented dbms_aqjms.aq$_update_prop_stat_qname(
qname           IN VARCHAR2,
db_link         IN VARCHAR2,
sequence_number IN BINARY_INTEGER,
status_code     IN BINARY_INTEGER);
TBD
 
CLEAR_DBSESSION_GUID
Undocumented dbms_aqjms.clear_dbsession_guid;
exec dbms_aqjms.clear_dbsession_guid;

PL/SQL procedure successfully completed.
 
CLEAR_GLOBAL_AQCLNTDB_CTX_CLNT
Undocumented dbms_aqjms.clear_global_aqclntdb_ctx_clnt(
client_session_guid IN VARCHAR2,
db_session_guid     IN VARCHAR2);
TBD
 
CLEAR_GLOBAL_AQCLNTDB_CTX_DB
Undocumented dbms_aqjms.clear_global_aqclntdb_ctx_db(db_session_guid IN VARCHAR2);
TBD
 
FETCHNONPERSDATA_12C_CALLOUT
Undocumented dbms_aqjms.fetchnonpersdata_12c_callout(
memctx  IN  RAW,
owner   IN  VARCHAR2,
queue   IN  VARCHAR2,
prptyp  IN  NUMBER,
located OUT VARCHAR2);
TBD
 
GET_DB_USERNAME_FOR_AGENT
Undocumented dbms_aqjms.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,
db_username  OUT VARCHAR2,
enq_priv     OUT BINARY_INTEGER,
deq_priv     OUT BINARY_INTEGER);
TBD
 
GET_NUMVAL
Undocumented dbms_aqjms.get_numval(
prop_name IN VARCHAR2,
prop_list IN sys.aq$_jms_userproparray)
RETURN NUMBER;
TBD
 
GET_PTYPE
Undocumented dbms_aqjms.get_ptype(
prop_name IN VARCHAR2,
prop_list IN sys.aq$_jms_userproparray)
RETURN BINARY_INTEGER;
TBD
 
GET_STRVAL
Undocumented dbms_aqjms.get_strval(
prop_name IN VARCHAR2,
prop_list IN sys.aq$_jms_userproparray)
RETURN VARCHAR2;
TBD
 
SEARCH_BOOLEAN_PROPERTY
Undocumented dbms_aqjms.search_boolean_property(
memctx           IN RAW,
property_name    IN VARCHAR2,
owner            IN VARCHAR2,
queue            IN VARCHAR2,
row_id           IN VARCHAR2,
ifheaderproperty IN NUMBER)
RETURN NUMBER;
TBD
 
SEARCH_DOUBLE_PROPERTY
Undocumented dbms_aqjms.search_double_property(
memctx           IN RAW,
property_name    IN VARCHAR2,
owner            IN VARCHAR2,
queue            IN VARCHAR2,
row_id           IN VARCHAR2,
ifheaderproperty IN NUMBER)
RETURN DOUBLE;
TBD
 
SEARCH_NUMBER_PROPERTY
Undocumented dbms_aqjms.search_number_property(
memctx           IN RAW,
property_name    IN VARCHAR2,
owner            IN VARCHAR2,
queue            IN VARCHAR2,
row_id           IN VARCHAR2,
ifheaderproperty IN NUMBER)
RETURN NUMBER;
TBD
 
SEARCH_STRING_PROPERTY
Undocumented dbms_aqjms.search_string_property(
memctx           IN RAW,
property_name    IN VARCHAR2,
owner            IN VARCHAR2,
queue            IN VARCHAR2,
row_id           IN VARCHAR2,
ifheaderproperty IN NUMBER)
RETURN VARCHAR2;
TBD
 
SET_DBSESSION_GUID
Undocumented dbms_aqjms.set_dbsession_guid(db_session_guid IN VARCHAR2);
TBD
 
SET_GLOBAL_AQCLNTDB_CTX
Undocumented dbms_aqjms.set_global_aqclntdb_ctx(
client_session_guid IN VARCHAR2,
db_session_guid     IN VARCHAR2);
TBD
 
SUBSCRIBER_EXISTS
Undocumented

Overload 1
dbms_aqjms.subscriber_exists(
queue_name     IN  VARCHAR2,
subscriber     IN  sys.aq$_agent,
in_subscr_type IN  NUMBER,
subscr_type    OUT NUMBER,
rule_name      OUT VARCHAR2,
trans_name     OUT VARCHAR2,
ruleset        OUT VARCHAR2,
result         OUT NUMBER);
TBD
Undocumented

Overload 2
dbms_aqjms.subscriber_exists(
queue_name       IN  VARCHAR2,
subscriber       IN  sys.aq$_agent,
in_subscr_type   IN  NUMBER,
subscr_type      OUT NUMBER,
rule_name        OUT VARCHAR2,
trans_name       OUT VARCHAR2,
ruleset          OUT VARCHAR2,
negative_ruleset OUT VARCHAR2,
result           OUT NUMBER);
TBD

Related Topics
Built-in Functions
Built-in Packages
Database Security
DBMS_AQ
DBMS_AQJMS_INTERNAL
What's New In 19c
What's New In 20c-21c

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-2022 Daniel A. Morgan All Rights Reserved
  DBSecWorx