Oracle | DBMS_AQJMS

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