DBA Data[Home] [Help]

VIEW: APPLSYS.AQ$_WF_CONTROL_F

Source

View Text - Preformatted

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
View Text - HTML Formatted

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