Oracle | DBMS_AQJMS

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	AQ$_JMS_ENQUEUE_MESSAGES	CREATE_STREAM_MESSAGE
AQ$_GET_TRANS_TYPE	AQ$_JMS_ENQUEUE_OBJ_MESSAGES	CREATE_TEXT_MESSAGE
AQ$_JMS_DEQUEUE_BYTES_MESSAGES	AQ$_JMS_ENQUEUE_STR_MESSAGES	ENQUEUE_BYTES_INTERNAL
AQ$_JMS_DEQUEUE_MAP_MESSAGES	AQ$_JMS_ENQUEUE_TEXT_MESSAGES	ENQUEUE_GENERIC_INTERNAL
AQ$_JMS_DEQUEUE_MESSAGES	AQ$_PURGE_MESSAGE	ENQUEUE_MAP_INTERNAL
AQ$_JMS_DEQUEUE_OBJ_MESSAGES	AQ$_UPDATE_PROP_STAT	ENQUEUE_OBJECT_INTERNAL
AQ$_JMS_DEQUEUE_STR_MESSAGES	CREATE_BYTES_MESSAGE	ENQUEUE_STREAM_INTERNAL
AQ$_JMS_DEQUEUE_TEXT_MESSAGES	CREATE_GENERIC_MESSAGE	ENQUEUE_TEXT_INTERNAL
AQ$_JMS_ENQUEUE_BYTES_MESSAGES	CREATE_MAP_MESSAGE	FLATTEN_JMS
AQ$_JMS_ENQUEUE_MAP_MESSAGES	CREATE_OBJECT_MESSAGE	GET_DB_USERNAME_FOR_AGENT

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