Oracle | DBMS_PRVTAQIP

Oracle DBMS_PRVTAQIP 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 Utilities (a substantial percentage of the subprograms are likely deprecated)

AUTHID DEFINER

Constants

Name	Data Type	Value
Constants found in execaq.sql used by DBMS_SCHEDULER.DEFINE_PROGRAM_ARGUMENT
DEFAULT_DEQUEUE_TIMEOUT	Not Known	100
DEFAULT_IDLE_TIMEOUT	Not Known	240
DEFAULT_TRACE_LEVEL	Not Known	0

Dependencies

ALL_QUEUES	DBMS_AQADM_INV	DBMS_SERVER_ALERT_PRVT
AQ$_AGENT	DBMS_AQADM_LIB	DBMS_SQL
AQ$_MESSAGE_TYPES	DBMS_AQADM_SYS	DBMS_STATS_INTERNAL
AQ$_NOTIFY_MSG	DBMS_AQADM_SYSCALLS	DBMS_SYSTEM
AQ$_PENDING_MESSAGES	DBMS_AQADM_VAR	DBMS_SYS_ERROR
AQ$_PROPAGATION_STATUS	DBMS_AQINT_LIB	DBMS_SYS_SQL
AQ$_QUEUES	DBMS_AQ_LIB	DBMS_TRANSACTION
AQ$_QUEUE_TABLES	DBMS_ASSERT	DBMS_UTILITY
AQ$_QUEUE_TABLE_AFFINITIES	DBMS_IJOB	DUAL
AQ$_REPLAY_INFO	DBMS_ISCHED	GV$INSTANCE
AQ$_SCHEDULES	DBMS_JOB	PROPS$
COL$	DBMS_LOB	STREAMS$_PROPAGATION_PROCESS
COLTYPE$	DBMS_LOCK	UTL_HTTP
DBA_JOBS	DBMS_LOGREP_UTIL	V$INSTANCE
DBA_SCHEDULER_JOBS	DBMS_SCHEDULER	X$KSPPCV
DBMS_AQ	DBMS_SERVER_ALERT	X$KSPPI
DBMS_AQADM

Documented No

First Available Not known but likely 10.2

Security Model Owned by SYS with no privileges granted

Source {ORACLE_HOME}/rdbms/admin/dbmsaqds.plb
{ORACLE_HOME}/rdbms/admin/prvtaqip.plb

Subprograms

ALTER_PROPAGATION_SCHEDULE	GET_SEQNO_HTTP	SCHEDULE_PROPAGATION
CREATE_PROP_TABLE_102	HTTP_COMMIT	TRANS_SCHED_INFO
CRT_XMLCMT_REQ	HTTP_PUSH	TRUNCATE_PENDING_MESSAGES
CRT_XMLRBK_REQ	HTTP_ROLLBACK	TYPE_MATCHES
CRT_XMLSEQ_REQ	IS_PROTO_SSL	UPDATE_AQS_INSTANCE_102
CRT_XMLTYP_REQ	I_UNSCHED_PROP	UPDATE_PROPJOB_AFFINITY_102
DEQ_NFY_QUEUE_102	KWQP_3GL_MODPSENTRY	UPDATE_SCHEDULE
DISABLE_PROPAGATION_SCHEDULE	NEEDS_RECOVERY	UPDATE_SCHEDULE_CLEAR_ERROR
ENABLE_PROPAGATION_SCHEDULE	RECOVER_PROPAGATION	WRITE_REQUEST
ENQ_NFY_QUEUE_102	RESUBMIT_JOBS_102	WRITE_TRACE
GET_SCHED_TYPE

ALTER_PROPAGATION_SCHEDULE

Undocumented dbms_prvtaqip.alter_propagation_schedule( queue_name IN VARCHAR2, destination IN VARCHAR2, duration IN NUMBER, next_time IN VARCHAR2, latency IN NUMBER, qname IN VARCHAR2, myoid IN RAW, canon_dest IN VARCHAR2, current_user IN VARCHAR2);

TBD

CREATE_PROP_TABLE_102

Undocumented dbms_prvtaqip.create_prop_102( qname IN VARCHAR2, instance_num IN NUMBER, check_compatible IN BOOLEAN);

TBD

CRT_XMLCMT_REQ

Undocumented dbms_prvtaqip.crt_xmlcmt_req(request OUT VARCHAR2);

DECLARE

       outVal dbms_id;

      BEGIN

        dbms_prvtaqip.crt_xmlcmt_req(outVal);

        dbms_output.put_line(outVal);

      END;

      /

CRT_XMLRBK_REQ

Undocumented dbms_prvtaqip.crt_xmlrbk_req(request OUT VARCHAR2);

DECLARE

       outVal dbms_id;

      BEGIN

        dbms_prvtaqip.crt_xmlrbk_req(outVal);

        dbms_output.put_line(outVal);

      END;

      /

CRT_XMLSEQ_REQ

Undocumented dbms_prvtaqip.crt_xmlseq_req( dblink IN VARCHAR2, queue IN VARCHAR2, qid IN NUMBER, request OUT VARCHAR2);

TBD

CRT_XMLTYP_REQ

Undocumented dbms_prvtaqip.crt_xmltyp_req( queue IN VARCHAR2, request OUT VARCHAR2);

TBD

DEQ_NFY_QUEUE_102

Undocumented dbms_prvtaqip.deq_nfy_queue_102( recipient IN VARCHAR2, instance IN NUMBER, incorrid IN VARCHAR2, wait IN BINARY_INTEGER, opcode OUT NUMBER, qid OUT RAW, dest OUT VARCHAR2, destl OUT NUMBER, outcorrid OUT VARCHAR2, outcorridl OUT NUMBER, msgfound OUT NUMBER);

TBD

DISABLE_PROPAGATION_SCHEDULE

Undocumented dbms_prvtaqip.disable_propagation_schedule( queue_schema IN VARCHAR2, queue_name IN VARCHAR2, destination IN VARCHAR2, myoid IN RAW, canon_dest IN VARCHAR2);

TBD

ENABLE_PROPAGATION_SCHEDULE

Undocumented dbms_prvtaqip.enable_propagation_schedule( queue_schema IN VARCHAR2, queue_name IN VARCHAR2, destination IN VARCHAR2, myoid IN RAW, canon_dest IN VARCHAR2);

TBD

ENQ_NFY_QUEUE_102

Undocumented dbms_prvtaqip.enq_nfy_queue_102( recipient IN VARCHAR2, instance IN NUMBER, opcode IN NUMBER, qid IN RAW, dest IN VARCHAR2, corrid IN VARCHAR2, expiration IN BINARY_INTEGER);

TBD

GET_SCHED_TYPE

Undocumented dbms_prvtaqip.get_sched_type( qt_flags IN BINARY_INTEGER, start_time IN DATE duration IN NUMBER, latency IN NUMBER, next_time IN VARCHAR2);

TBD

GET_SEQNO_HTTP

Undocumented =dbms_prvtaqip.get_seqno_http( url IN VARCHAR2, username IN VARCHAR2, passwd IN VARCHAR2, dest IN VARCHAR2, queue IN VARCHAR2, qid IN NUMBER, trace IN BINARY_INTEGER, status_code OUT NUMBER, remoteseq OUT NUMBER);

TBD

HTTP_COMMIT

Undocumented dbms_prvtaqip.http_commit( url IN VARCHAR2, username IN VARCHAR2, passwd IN VARCHAR2, trace IN BINARY_INTEGER);

TBD

HTTP_PUSH

Undocumented dbms_prvtaqip.http_push( url IN VARCHAR2, username IN VARCHAR2, passwd IN VARCHAR2, trace IN BINARY_INTEGER, resp OUT VARCHAR2, xmldoc IN CLOB);

TBD

HTTP_ROLLBACK

Undocumented dbms_prvtaqip.http_rollback( url IN VARCHAR2, username IN VARCHAR2, passwd IN VARCHAR2, trace IN BINARY_INTEGER);

TBD

IS_PROTO_SSL

Undocumented dbms_prvtaqip.is_proto_ssl(url IN VARCHAR2) RETURN BOOLEAN,;

TBD

I_UNSCHED_PROP

Undocumented dbms_prvtaqip.i_unsched_prop( myoid IN RAW, queue_schema IN VARCHAR2, queue_name IN VARCHAR2, canon_dest IN VARCHAR2, synchronous IN BOOLEAN, propagation_name IN VARCHAR2) RETURN BINARY_INTEGER,;

TBD

KWQP_3GL_MODPSENTRY

Undocumented dbms_prvtaqip.kwqp_3gl_modsentry( operation IN BINARY_INTEGER, qid IN NUMBER, queue_schema IN VARCHAR2, queue_name IN VARCHAR2, destination IN VARCHAR2, job_name IN VARCHAR2, prop_name IN VARCHAR2, queue_to_queue IN BOOLEAN);

TBD

NEEDS_RECOVERY

Undocumented dbms_prvtaqip.needs_recovery( schema IN VARCHAR2, qtname IN VARCHAR2) RETURN BOOLEAN,;

exec dbms_prvtaqip.needs_recovery(

RECOVER_PROPAGATION

Undocumented dbms_prvtaqip.recover_propagation( schema IN VARCHAR2, qname IN VARCHAR2, dest IN VARCHAR2, protocol IN BINARY_INTEGER, url IN VARCHAR2, username IN VARCHAR2, passwd IN VARCHAR2, trace IN BINARY_INTEGER, destq IN BINARY_INTEGER, current_user IN VARCHAR2);

TBD

RESUBMIT_JOBS_102

Undocumented dbms_prvtaqip.resubmit_jobs_102(job IN NUMBER);

exec dbms_prvtaqip.resubmit_jobs_102(42);

      

      PL/SQL procedure successfully completed.

SCHEDULE_PROPAGATION

Undocumented dbms_prvtaqip.schedule_propagation( queue_schema IN VARCHAR2, queue_name IN VARCHAR2, destination IN VARCHAR2, start_time IN TIMESTAMP WITH TIME ZONE duration IN NUMBER, next_time IN VARCHAR2, latency IN NUMBER, myoid IN RAW, canon_dest IN VARCHAR2, destinationq IN BOOLEAN, propagation_name IN VARCHAR2);

TBD

TRANS_SCHED_INFO

Undocumented dbms_prvtaqip.trans_sched_info( qid IN RAW, dest IN VARCHAR2, sess_id IN NUMBER, sess_serial IN NUMBER, schema OUT VARCHAR2, schemal OUT NUMBER, qname OUT VARCHAR2, qnamel OUT NUMBER, p_start_time OUT DATE duration OUT NUMBER, durationind OUT NUMBER, next_time OUT VARCHAR2, lnext_time OUT NUMBER, latency OUT NUMBER, latencyind OUT NUMBER, toid OUT RAW, toidind OUT NUMBER, version OUT NUMBER, schedind OUT NUMBER, qusage OUT NUMBER, qeventid OUT NUMBER, http_batchsz OUT NUMBER, err_msg OUT NUMBER);

TBD

TRUNCATE_PENDING_MESSAGES

Undocumented dbms_prvtaqip.truncate_pending_messages;

exec dbms_prvtaqip.truncate_pending_messages;

      

      PL/SQL procedure successfully completed.

TYPE_MATCHES

Undocumented dbms_prvtaqip.type_matches( qoid IN RAW, address IN VARCHAR2, dest IN VARCHAR2) RETURN BOOLEAN,;

TBD

UPDATE_AQS_INSTANCE_102

Undocumented dbms_prvtaqip.update_aqs_instance_102;

exec dbms_prvtaqip.update_aqs_instance_102;

      

      PL/SQL procedure successfully completed.

UPDATE_PROPJOB_AFFINITY_102

Undocumented dbms_prvtaqip.update_propjob_affinity_102( qtableno IN NUMBER, newinstance IN NUMBER);

TBD

UPDATE_SCHEDULE

Undocumented dbms_prvtaqip.update_schedule( prop_time IN NUMBER, msgs IN NUMBER, bytes IN NUMBER, err_msg IN VARCHAR2, schema IN VARCHAR2, qname IN VARCHAR2, qid IN RAW, dest IN VARCHAR2, force IN NUMBER, trace IN NUMBER, http_batchsz IN NUMBER, continue_prop OUT NUMBER, schedind OUT NUMBER, gnoreerr IN NUMBER, propstyle102 IN NUMBER);

TBD

UPDATE_SCHEDULE_CLEAR_ERROR

Undocumented dbms_prvtaqip.update_schedule_clear_error( qid IN RAW, dest IN VARCHAR2, jobno IN NUMBER);

TBD

WRITE_REQUEST

Undocumented dbms_prvtaqip.write_request( request IN OUT sys.utl_http.req, xmldoc IN CLOB);

TBD

WRITE_TRACE

Undocumented dbms_prvtaqip.write_trace( trace_level IN BINARY_INTEGER, level IN BINARY_INTEGER, message IN VARCHAR2);

TBD