dbms_aqmigtool_sys.add_subscriber_to_txeventq(
cq_schema IN VARCHAR2,
cq_name IN VARCHAR2,
cqt_name IN VARCHAR2,
teq_schema IN VARCHAR2,
teq_name IN VARCHAR2,
is repl IN BOOLEAN,
current_user IN VARCHAR2);
dbms_aqmigtool_sys.add_subscriber_to_txeventq_int(
cq_schema IN VARCHAR2,
cq_name IN VARCHAR2,
cqt_name IN VARCHAR2,
teq_schema IN VARCHAR2,
teq_name IN VARCHAR2,
is repl IN BOOLEAN,
current_user IN VARCHAR2);
dbms_aqmigtool_sys.check_unsupported_feature(
q_schema IN VARCHAR2,
q_name IN VARCHAR2,
event OUT VARCHAR2,
event_err OUT VARCHAR2,
warning_check IN BOOLEAN)
RETURN BOOLEAN;
dbms_aqmigtool_sys.copy_msg_txeventtq_to_cq_int(
cq_schema IN VARCHAR2,
cq_name IN VARCHAR2,
teq_schema IN VARCHAR2,
teq_name IN VARCHAR2,
current_uesr IN VARCHAR2);
dbms_aqmigtool_sys.copy_msg_txeventtq_to_cq_repl(
cq_schema IN VARCHAR2,
cq_name IN VARCHAR2,
teq_schema IN VARCHAR2,
teq_name IN VARCHAR2,
current_uesr IN VARCHAR2);
dbms_aqmigtool_sys.copy_plsql_notification(
src_schema IN VARCHAR2,
src_qname IN VARCHAR2,
dst_schema IN VARCHAR2,
dst_qname IN VARCHAR2,
only_update IN BOOLEAN,
is_repl IN BOOLEAN);
dbms_aqmigtool_sys.create_exception_queue(
q_schema IN VARCHAR2,
qt_name IN VARCHAR2,
teq_schema IN VARCHAR2,
teq_name IN VARCHAR2,
is_repl IN BOOLEAN,
current_user IN VARCHAR2);
dbms_aqmigtool_sys.enqueue_to_cq(
cq_schema IN VARCHAR2,
cq_name IN VARCHAR2,
teq_schema IN VARCHAR2,
teq_name IN VARCHAR2,
cq_msgid IN RAW,
teq_msgid IN RAW,
teq_delay IN BINARY_INTEGER,
teq_correlation IN VARCHAR2,
teq_enqueue_time IN TIMESTAMP,
teq_priority IN NUMBER,
teq_state IN NUMBER,
teq_enq_uid IN VARCHAR2,
cq_step_no IN BINARY_INTEGER,
teq_payload_code IN NUMBER,
adt_type_owner IN VARCHAR2,
ad__type_name IN VARCHAR2,
subshard_part IN VARCHAR2);
dbms_aqmigtool_sys.get_cq_metadata(
q_schema IN VARCHAR2,
q_name IN VARCHAR2,
queue_properties IN OUT sys.dbms_aqadm.quque_props,
storage_clause IN OUT VARCHAR2,
multiple_consumers IN OUT BOOLEAN,
max_retries IN OUT NUMBER,
queue_payload_owner IN OUT VARCHAR2,
queue_payload_type IN OUT VARCHAR2,
qt_name IN OUT VARCHAR2,
udata_type IN OUT NUMBER,
replication_mode IN OUT BINARY_INTEGER,
current_user IN VARCHAR2);
dbms_aqmigtool_sys.get_latest_migration_state_record(
cq_schema IN VARCHAR2,
cq_name IN VARCHAR2,
teq_schema OUT VARCHAR2,
teq_name OUT VARCHAR2,
event_id_p OUT NUMBER,
phase OUT NUMBER)
RETURN BOOLEAN;
dbms_aqmigtool_sys.get_into_durable_subs_int(
q_schema IN VARCHAR2,
q_id IN NUMBER,
q_name IN VARCHAR2,
qt_objno IN NUMBER,
subs_id IN NUMBER,
subs_name IN VARCHAR2,
subs_address IN VARCHAR2,
subs_protocol IN NUMBER,
subs_type IN NUMBER,
pos_bitmap IN NUMBER,
rule_name IN VARCHAR2,
creation_time IN TIMESTAMP WITH TIME ZONE);
dbms_aqmigtool_sys.get_into_durable_subs_repl(
q_schema IN VARCHAR2,
q_id IN NUMBER,
q_name IN VARCHAR2,
qt_objno IN NUMBER,
subs_id IN NUMBER,
subs_name IN VARCHAR2,
subs_address IN VARCHAR2,
subs_protocol IN NUMBER,
subs_type IN NUMBER,
pos_bitmap IN NUMBER,
rule_name IN VARCHAR2,
creation_time IN TIMESTAMP WITH TIME ZONE);
dbms_aqmigtool_sys.insert_mig_status(
is_repl IN BOOLEAN,
migration_id IN RAW,
s_schema IN VARCHAR2,
s_queue IN VARCHAR2,
status IN NUMBER,
event IN VARCHAR2,
event_id IN NUMBER,
event_error IN VARCHAR2,
t_schema IN VARCHAR2,
t_queue IN VARCHAR2,
s_qtname IN VARCHAR2,
ordering IN VARCHAR2,
suffix IN VARCHAR2,
mig_mode IN NUMBER,
spare1 IN NUMBER);
dbms_aqmigtool_sys.insert_mig_status_commit(
is_repl IN BOOLEAN,
migration_id IN RAW,
s_schema IN VARCHAR2,
s_queue IN VARCHAR2,
s_qtname IN VARCHAR2,
t_schema IN VARCHAR2,
t_queue IN VARCHAR2,
status IN NUMBER,
event IN VARCHAR2,
event_id IN NUMBER,
event_error IN VARCHAR2,
ordering IN VARCHAR2,
suffix IN VARCHAR2,
mig_mode IN NUMBER,
spare1 IN NUMBER);
dbms_aqmigtool_sys.insert_mig_status_commit_int(
migration_id IN RAW,
s_schema IN VARCHAR2,
s_queue IN VARCHAR2,
s_qtname IN VARCHAR2,
t_schema IN VARCHAR2,
t_queue IN VARCHAR2,
status IN NUMBER,
event IN VARCHAR2,
event_id IN NUMBER,
event_error IN VARCHAR2,
ordering IN VARCHAR2,
suffix IN VARCHAR2,
mig_mode IN NUMBER,
spare1 IN NUMBER,
event_time IN TIMESTAMP WITH TIME ZONE;
dbms_aqmigtool_sys.insert_mig_status_commit_repl(
migration_id IN RAW,
s_schema IN VARCHAR2,
s_queue IN VARCHAR2,
s_qtname IN VARCHAR2,
t_schema IN VARCHAR2,
t_queue IN VARCHAR2,
status IN NUMBER,
event IN VARCHAR2,
event_id IN NUMBER,
event_error IN VARCHAR2,
ordering IN VARCHAR2,
suffix IN VARCHAR2,
mig_mode IN NUMBER,
spare1 IN NUMBER,
event_time IN TIMESTAMP WITH TIME ZONE;
dbms_aqmigtool_sys.insert_mig_status_int(
migration_id IN RAW,
s_schema IN VARCHAR2,
s_queue IN VARCHAR2,
status IN NUMBER,
event IN VARCHAR2,
event_id IN NUMBER,
event_error IN VARCHAR2,
t_schema IN VARCHAR2,
t_queue IN VARCHAR2,
ordering IN VARCHAR2,
suffix IN VARCHAR2,
mig_mode IN NUMBER,
spare1 IN NUMBER,
event_time IN TIMESTAMP WITH TIME ZONE;
dbms_aqmigtool_sys.insert_mig_status_repl(
migration_id IN RAW,
s_schema IN VARCHAR2,
s_queue IN VARCHAR2,
status IN NUMBER,
event IN VARCHAR2,
event_id IN NUMBER,
event_error IN VARCHAR2,
t_schema IN VARCHAR2,
t_queue IN VARCHAR2,
ordering IN VARCHAR2,
suffix IN VARCHAR2,
mig_mode IN NUMBER,
spare1 IN NUMBER,
event_time IN TIMESTAMP WITH TIME ZONE;
dbms_aqmigtool_sys.rename_txeventq_int(
q_schema IN VARCHAR2,
q_name_old IN VARCHAR2,
q_name_new IN VARCHAR2,
call_from_migration IN BOOLEAN,
current_user IN VARCHAR2);
dbms_aqmigtool_sys.rename_txeventq_repl(
q_schema IN VARCHAR2,
q_name_old IN VARCHAR2,
q_name_new IN VARCHAR2,
call_from_migration IN BOOLEAN,
current_user IN VARCHAR2);
dbms_aqmigtool_sys.update_mig_status_commit_int(
s_schema IN VARCHAR2,
s_queue IN VARCHAR2,
status IN NUMBER,
event_id IN NUMBER,
spare1 IN NUMBER,
event_err IN VARCHAR2);
dbms_aqmigtool_sys.update_mig_status_commit_repl(
s_schema IN VARCHAR2,
s_queue IN VARCHAR2,
status IN NUMBER,
event_id IN NUMBER,
spare1 IN NUMBER,
event_err IN VARCHAR2);
dbms_aqmigtool_sys.update_mig_status_int(
s_schema IN VARCHAR2,
s_queue IN VARCHAR2,
status IN NUMBER,
event_id IN NUMBER,
spare1 IN NUMBER,
event_err IN VARCHAR2);
dbms_aqmigtool_sys.update_mig_status_repl(
s_schema IN VARCHAR2,
s_queue IN VARCHAR2,
status_p IN NUMBER,
event_id_p IN NUMBER,
spare1_p IN NUMBER,
event_err_p IN VARCHAR2);
dbms_aqmigtool_sys.update_retry_count(
cq_schema IN VARCHAR2,
cq_msgid IN RAW,
subscriber_id IN NUMBER,
teq_retry_count IN NUMBER,
retry_cnt_stmt IN VARCHAR2);
dbms_aqmigtool_sys.update_subscriber_state(
cq_schema IN VARCHAR2,
cq_name
IN VARCHAR2,
teq_schema IN VARCHAR2,
teq_name IN VARCHAR2,
teq_table_no IN NUMBER,
qt_phys_offset IN NUMBER,
subshard_size IN NUMBER,
subshare_part_no IN NUMBER,
subshard_no IN NUMBER,
subscriber_lwm IN NUMBER,
retry_cnt_stmt IN VARCHAR2,
subscriber_id IN NUMBER,
subscriber_name IN VARCHAR2,
cq_msgid IN RAW,
teq_msgid IN RAW,
teq_step_number IN NUMBER,
multiple_consumers IN BOOLEAN);