Oracle | DBMS

Oracle DBMS_AQJMS 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 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