Oracle | DBMS

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	AQ$_JMS_ENQUEUE_MAP_MESSAGES	CLEAR_GLOBAL_AQCLNTDB_CTX_CLNT
AQ$_ADD_NONDURABLE_SUB_SQ	AQ$_JMS_ENQUEUE_MESSAGES	CLEAR_GLOBAL_AQCLNTDB_CTX_DB
AQ$_ADD_SUBSCRIBER	AQ$_JMS_ENQUEUE_OBJ_MESSAGES	FETCHNONPERSDATA_12C_CALLOUT
AQ$_ALTER_SUBSCRIBER	AQ$_JMS_ENQUEUE_STR_MESSAGES	GET_DB_USERNAME_FOR_AGENT
AQ$_DROPNONDURABLE_SUB_SQ	AQ$_JMS_ENQUEUE_TEXT_MESSAGES	GET_NUMVAL
AQ$_GET_PROP_STAT	AQ$_PR	GET_PTYPE
AQ$_GET_TRANS_TYPE	AQ$_PURGE_MESSAGE	GET_STRVAL
AQ$_JMS_DEQUEUE_BYTES_MESSAGES	AQ$_REGISTER	SEARCH_BOOLEAN_PROPERTY
AQ$_JMS_DEQUEUE_MAP_MESSAGES	AQ$_REMOVE_SUBSCRIBER	SEARCH_DOUBLE_PROPERTY
AQ$_JMS_DEQUEUE_MESSAGES	AQ$_REM_NONDURABLE_SUBSCRIBER	SEARCH_NUMBER_PROPERTY
AQ$_JMS_DEQUEUE_OBJ_MESSAGES	AQ$_UNREGISTER	SEARCH_STRING_PROPERTY
AQ$_JMS_DEQUEUE_STR_MESSAGES	AQ$_UPDATE_PROP_STAT	SET_DBSESSION_GUID
AQ$_JMS_DEQUEUE_TEXT_MESSAGES	AQ$_UPDATE_PROP_STAT_QNAME	SET_GLOBAL_AQCLNTDB_CTX
AQ$_JMS_ENQUEUE_BYTES_MESSAGES	CLEAR_DBSESSION_GUID	SUBSCRIBER_EXISTS

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