SELECT /*+ NO_MERGE (qo) USE_NL(iot) */ qt.q_name Q_NAME, qt.rowid ROW_ID, qt.msgid MSGID, qt.corrid CORRID, qt.priority PRIORITY, qt.state STATE, cast(FROM_TZ(qt.delay, '-08:00') at time zone sessiontimezone as timestamp) DELAY, qt.expiration EXPIRATION, cast(FROM_TZ(qt.enq_time, '-08:00') at time zone sessiontimezone as timestamp) ENQ_TIME, qt.enq_uid ENQ_UID, qt.enq_tid ENQ_TID, cast(FROM_TZ(qt.deq_time, '-08:00') at time zone sessiontimezone as timestamp) DEQ_TIME, qt.deq_uid DEQ_UID, qt.deq_tid DEQ_TID, qt.retry_count RETRY_COUNT, qt.exception_qschema EXCEPTION_QSCHEMA, qt.exception_queue EXCEPTION_QUEUE, qt.cscn CSCN, qt.dscn DSCN, qt.chain_no CHAIN_NO, qt.local_order_no LOCAL_ORDER_NO, cast(FROM_TZ(qt.time_manager_info, '-08:00') at time zone sessiontimezone as timestamp) TIME_MANAGER_INFO, qt.step_no STEP_NO, qt.user_data USER_DATA, qt.sender_name SENDER_NAME, qt.sender_address SENDER_ADDRESS, qt.sender_protocol SENDER_PROTOCOL, qt.dequeue_msgid DEQUEUE_MSGID, 'PERSISTENT' DELIVERY_MODE, 0 SEQUENCE_NUM, 0 MSG_NUM, qo.qid QUEUE_ID, qt.user_prop USER_PROP, iot.subscriber# SUBSCRIBER_ID, iot.name SUBSCRIBER_NAME, iot.queue# QUEUE_EVTID FROM "WF_CONTROL" qt, "AQ$_WF_CONTROL_I" iot, SYS.ALL_INT_DEQUEUE_QUEUES qo WHERE qt.msgid=iot.msgid and qt.q_name = qo.name AND qo.owner = 'APPLSYS' AND iot.msg_priority = qt.priority AND iot.msg_enq_time = qt.enq_time AND iot.msg_step_no = qt.step_no AND iot.msg_local_order_no = qt.local_order_no AND iot.msg_chain_no = qt.chain_no UNION ALL SELECT qo.name Q_NAME, cast (null as rowid) ROW_ID, b.msgid MSGID, b.corrid CORRID, b.priority PRIORITY, decode(b.state, 4, 0, 5, 8, 12, 10, 0) STATE, cast (null as TIMESTAMP) DELAY, b.expiration EXPIRATION, cast(FROM_TZ(b.enq_time, '-08:00') at time zone sessiontimezone as timestamp) ENQ_TIME, b.enq_uid ENQ_UID, cast(null as varchar2(30)) ENQ_TID, cast(null as timestamp) DEQ_TIME, cast (null as number) DEQ_UID, cast (null as varchar2(30)) DEQ_TID, 0 RETRY_COUNT, b.exceptionq_schema EXCEPTION_QUEUE_OWNER, b.exceptionq_name EXCEPTION_QUEUE, 0 CSCN, 0 DSCN, 0 CHAIN_NO, 0 LOCAL_ORDER_NO, cast (null as TIMESTAMP) TIME_MANAGER_INFO, 0 STEP_NO, sys.dbms_aq_bqview.get_adt_payload(b.queue_id, b.msg_num, "SYS"."AQ$_JMS_TEXT_MESSAGE"(NULL, NULL, NULL, NULL)) USER_DATA, b.sender_name SENDER_NAME, b.sender_address SENDER_ADDRESS, b.sender_protocol SENDER_PROTOCOL, cast(null as raw(16)) DEQUEUE_MSGID, 'BUFFERED' DELIVERY_MODE, b.sequence_num SEQUENCE_NUM, b.msg_num MSG_NUM, qo.qid QUEUE_ID, null USER_PROP, b.subscriber_id SUBSCRIBER_ID, cast (null as varchar2(30)) SUBSCRIBER_NAME, 0 QUEUE_EVTID FROM SYS.qt245562_BUFFER b, sys.all_int_dequeue_queues qo WHERE bitand(b.state, 4) = 4 AND qo.qid =b.queue_id UNION ALL SELECT p.q_name Q_NAME, cast (null as rowid) ROW_ID, p.msgid MSGID, p.corrid CORRID, p.priority PRIORITY, p.state STATE, cast(FROM_TZ(p.delay, '-08:00') at time zone sessiontimezone as timestamp) DELAY, p.expiration EXPIRATION, cast(FROM_TZ(p.enq_time, '-08:00') at time zone sessiontimezone as timestamp) ENQ_TIME, p.enq_uid ENQ_UID, p.enq_tid ENQ_TID, cast(FROM_TZ(p.deq_time, '-08:00') at time zone sessiontimezone as timestamp) DEQ_TIME, p.deq_uid DEQ_UID, p.deq_tid DEQ_TID, p.retry_count RETRY_COUNT, p.exception_qschema EXCEPTION_QSCHEMA, p.exception_queue EXCEPTION_QUEUE, p.cscn CSCN, p.dscn DSCN, p.chain_no CHAIN_NO, p.local_order_no LOCAL_ORDER_NO, cast(FROM_TZ(p.time_manager_info, '-08:00') at time zone sessiontimezone as timestamp) TIME_MANAGER_INFO, p.step_no STEP_NO, p.user_data USER_DATA, p.sender_name SENDER_NAME, p.sender_address SENDER_ADDRESS, p.sender_protocol SENDER_PROTOCOL, cast (null as RAW(16)) DEQUEUE_MSGID, 'BUFFERED' DELIVERY_MODE, b.sequence_num SEQUENCE_NUM, b.msg_num MSG_NUM, qo.qid QUEUE_ID, null USER_PROP, b.subscriber_id SUBSCRIBER_ID, cast (null as varchar2(30)) SUBSCRIBER_NAME, 0 QUEUE_EVTID FROM "AQ$_WF_CONTROL_P" p, SYS.qt245562_BUFFER b, sys.all_int_dequeue_queues qo WHERE bitand(b.state, 2) = 2 AND p.msgid = b.msgid AND qo.qid = b.queue_id and p.q_name = qo.name WITH READ ONLY
SELECT /*+ NO_MERGE (QO) USE_NL(IOT) */ QT.Q_NAME Q_NAME
, QT.ROWID ROW_ID
, QT.MSGID MSGID
, QT.CORRID CORRID
, QT.PRIORITY PRIORITY
, QT.STATE STATE
, CAST(FROM_TZ(QT.DELAY
, '-08:00') AT TIME ZONE SESSIONTIMEZONE AS TIMESTAMP) DELAY
, QT.EXPIRATION EXPIRATION
, CAST(FROM_TZ(QT.ENQ_TIME
, '-08:00') AT TIME ZONE SESSIONTIMEZONE AS TIMESTAMP) ENQ_TIME
, QT.ENQ_UID ENQ_UID
, QT.ENQ_TID ENQ_TID
, CAST(FROM_TZ(QT.DEQ_TIME
, '-08:00') AT TIME ZONE SESSIONTIMEZONE AS TIMESTAMP) DEQ_TIME
, QT.DEQ_UID DEQ_UID
, QT.DEQ_TID DEQ_TID
, QT.RETRY_COUNT RETRY_COUNT
, QT.EXCEPTION_QSCHEMA EXCEPTION_QSCHEMA
, QT.EXCEPTION_QUEUE EXCEPTION_QUEUE
, QT.CSCN CSCN
, QT.DSCN DSCN
, QT.CHAIN_NO CHAIN_NO
, QT.LOCAL_ORDER_NO LOCAL_ORDER_NO
, CAST(FROM_TZ(QT.TIME_MANAGER_INFO
, '-08:00') AT TIME ZONE SESSIONTIMEZONE AS TIMESTAMP) TIME_MANAGER_INFO
, QT.STEP_NO STEP_NO
, QT.USER_DATA USER_DATA
, QT.SENDER_NAME SENDER_NAME
, QT.SENDER_ADDRESS SENDER_ADDRESS
, QT.SENDER_PROTOCOL SENDER_PROTOCOL
, QT.DEQUEUE_MSGID DEQUEUE_MSGID
, 'PERSISTENT' DELIVERY_MODE
, 0 SEQUENCE_NUM
, 0 MSG_NUM
, QO.QID QUEUE_ID
, QT.USER_PROP USER_PROP
, IOT.SUBSCRIBER# SUBSCRIBER_ID
, IOT.NAME SUBSCRIBER_NAME
, IOT.QUEUE# QUEUE_EVTID
FROM "WF_CONTROL" QT
, "AQ$_WF_CONTROL_I" IOT
, SYS.ALL_INT_DEQUEUE_QUEUES QO
WHERE QT.MSGID=IOT.MSGID
AND QT.Q_NAME = QO.NAME
AND QO.OWNER = 'APPLSYS'
AND IOT.MSG_PRIORITY = QT.PRIORITY
AND IOT.MSG_ENQ_TIME = QT.ENQ_TIME
AND IOT.MSG_STEP_NO = QT.STEP_NO
AND IOT.MSG_LOCAL_ORDER_NO = QT.LOCAL_ORDER_NO
AND IOT.MSG_CHAIN_NO = QT.CHAIN_NO UNION ALL SELECT QO.NAME Q_NAME
, CAST (NULL AS ROWID) ROW_ID
, B.MSGID MSGID
, B.CORRID CORRID
, B.PRIORITY PRIORITY
, DECODE(B.STATE
, 4
, 0
, 5
, 8
, 12
, 10
, 0) STATE
, CAST (NULL AS TIMESTAMP) DELAY
, B.EXPIRATION EXPIRATION
, CAST(FROM_TZ(B.ENQ_TIME
, '-08:00') AT TIME ZONE SESSIONTIMEZONE AS TIMESTAMP) ENQ_TIME
, B.ENQ_UID ENQ_UID
, CAST(NULL AS VARCHAR2(30)) ENQ_TID
, CAST(NULL AS TIMESTAMP) DEQ_TIME
, CAST (NULL AS NUMBER) DEQ_UID
, CAST (NULL AS VARCHAR2(30)) DEQ_TID
, 0 RETRY_COUNT
, B.EXCEPTIONQ_SCHEMA EXCEPTION_QUEUE_OWNER
, B.EXCEPTIONQ_NAME EXCEPTION_QUEUE
, 0 CSCN
, 0 DSCN
, 0 CHAIN_NO
, 0 LOCAL_ORDER_NO
, CAST (NULL AS TIMESTAMP) TIME_MANAGER_INFO
, 0 STEP_NO
, SYS.DBMS_AQ_BQVIEW.GET_ADT_PAYLOAD(B.QUEUE_ID
, B.MSG_NUM
, "SYS"."AQ$_JMS_TEXT_MESSAGE"(NULL
, NULL
, NULL
, NULL)) USER_DATA
, B.SENDER_NAME SENDER_NAME
, B.SENDER_ADDRESS SENDER_ADDRESS
, B.SENDER_PROTOCOL SENDER_PROTOCOL
, CAST(NULL AS RAW(16)) DEQUEUE_MSGID
, 'BUFFERED' DELIVERY_MODE
, B.SEQUENCE_NUM SEQUENCE_NUM
, B.MSG_NUM MSG_NUM
, QO.QID QUEUE_ID
, NULL USER_PROP
, B.SUBSCRIBER_ID SUBSCRIBER_ID
, CAST (NULL AS VARCHAR2(30)) SUBSCRIBER_NAME
, 0 QUEUE_EVTID
FROM SYS.QT245562_BUFFER B
, SYS.ALL_INT_DEQUEUE_QUEUES QO
WHERE BITAND(B.STATE
, 4) = 4
AND QO.QID =B.QUEUE_ID UNION ALL SELECT P.Q_NAME Q_NAME
, CAST (NULL AS ROWID) ROW_ID
, P.MSGID MSGID
, P.CORRID CORRID
, P.PRIORITY PRIORITY
, P.STATE STATE
, CAST(FROM_TZ(P.DELAY
, '-08:00') AT TIME ZONE SESSIONTIMEZONE AS TIMESTAMP) DELAY
, P.EXPIRATION EXPIRATION
, CAST(FROM_TZ(P.ENQ_TIME
, '-08:00') AT TIME ZONE SESSIONTIMEZONE AS TIMESTAMP) ENQ_TIME
, P.ENQ_UID ENQ_UID
, P.ENQ_TID ENQ_TID
, CAST(FROM_TZ(P.DEQ_TIME
, '-08:00') AT TIME ZONE SESSIONTIMEZONE AS TIMESTAMP) DEQ_TIME
, P.DEQ_UID DEQ_UID
, P.DEQ_TID DEQ_TID
, P.RETRY_COUNT RETRY_COUNT
, P.EXCEPTION_QSCHEMA EXCEPTION_QSCHEMA
, P.EXCEPTION_QUEUE EXCEPTION_QUEUE
, P.CSCN CSCN
, P.DSCN DSCN
, P.CHAIN_NO CHAIN_NO
, P.LOCAL_ORDER_NO LOCAL_ORDER_NO
, CAST(FROM_TZ(P.TIME_MANAGER_INFO
, '-08:00') AT TIME ZONE SESSIONTIMEZONE AS TIMESTAMP) TIME_MANAGER_INFO
, P.STEP_NO STEP_NO
, P.USER_DATA USER_DATA
, P.SENDER_NAME SENDER_NAME
, P.SENDER_ADDRESS SENDER_ADDRESS
, P.SENDER_PROTOCOL SENDER_PROTOCOL
, CAST (NULL AS RAW(16)) DEQUEUE_MSGID
, 'BUFFERED' DELIVERY_MODE
, B.SEQUENCE_NUM SEQUENCE_NUM
, B.MSG_NUM MSG_NUM
, QO.QID QUEUE_ID
, NULL USER_PROP
, B.SUBSCRIBER_ID SUBSCRIBER_ID
, CAST (NULL AS VARCHAR2(30)) SUBSCRIBER_NAME
, 0 QUEUE_EVTID
FROM "AQ$_WF_CONTROL_P" P
, SYS.QT245562_BUFFER B
, SYS.ALL_INT_DEQUEUE_QUEUES QO
WHERE BITAND(B.STATE
, 2) = 2
AND P.MSGID = B.MSGID
AND QO.QID = B.QUEUE_ID
AND P.Q_NAME = QO.NAME WITH READ ONLY
|
|
|