APPS.XDP_INTERFACES dependencies on DBMS_AQ

Line 2176: lv_DequeueOptions DBMS_AQ.DEQUEUE_OPTIONS_T;

2172: x_user_data OUT NOCOPY SYSTEM.XDP_WF_CHANNELQ_TYPE,
2173: x_lock_status OUT NOCOPY varchar2,
2174: x_error OUT NOCOPY varchar2)
2175: IS
2176: lv_DequeueOptions DBMS_AQ.DEQUEUE_OPTIONS_T;
2177: lv_MessageProperties DBMS_AQ.MESSAGE_PROPERTIES_T;
2178: lv_MsgID RAW(16);
2179: lv_user_data SYSTEM.XDP_WF_CHANNELQ_TYPE;
2180:

Line 2177: lv_MessageProperties DBMS_AQ.MESSAGE_PROPERTIES_T;

2173: x_lock_status OUT NOCOPY varchar2,
2174: x_error OUT NOCOPY varchar2)
2175: IS
2176: lv_DequeueOptions DBMS_AQ.DEQUEUE_OPTIONS_T;
2177: lv_MessageProperties DBMS_AQ.MESSAGE_PROPERTIES_T;
2178: lv_MsgID RAW(16);
2179: lv_user_data SYSTEM.XDP_WF_CHANNELQ_TYPE;
2180:
2181: BEGIN

Line 2186: lv_DequeueOptions.visibility := DBMS_AQ.ON_COMMIT;

2182: if( p_msg_id is NULL ) then
2183: return;
2184: end if;
2185: savepoint lv_q_tag;
2186: lv_DequeueOptions.visibility := DBMS_AQ.ON_COMMIT;
2187: lv_DequeueOptions.navigation := DBMS_AQ.FIRST_MESSAGE;
2188: lv_DequeueOptions.msgid := p_msg_id;
2189: lv_DequeueOptions.dequeue_mode := DBMS_AQ.LOCKED;
2190:

Line 2187: lv_DequeueOptions.navigation := DBMS_AQ.FIRST_MESSAGE;

2183: return;
2184: end if;
2185: savepoint lv_q_tag;
2186: lv_DequeueOptions.visibility := DBMS_AQ.ON_COMMIT;
2187: lv_DequeueOptions.navigation := DBMS_AQ.FIRST_MESSAGE;
2188: lv_DequeueOptions.msgid := p_msg_id;
2189: lv_DequeueOptions.dequeue_mode := DBMS_AQ.LOCKED;
2190:
2191: -- Set Dequeue time out to be 1 second

Line 2189: lv_DequeueOptions.dequeue_mode := DBMS_AQ.LOCKED;

2185: savepoint lv_q_tag;
2186: lv_DequeueOptions.visibility := DBMS_AQ.ON_COMMIT;
2187: lv_DequeueOptions.navigation := DBMS_AQ.FIRST_MESSAGE;
2188: lv_DequeueOptions.msgid := p_msg_id;
2189: lv_DequeueOptions.dequeue_mode := DBMS_AQ.LOCKED;
2190:
2191: -- Set Dequeue time out to be 1 second
2192: lv_DequeueOptions.wait := 1;
2193: x_lock_status := G_LOCK_MSG_SUCCESS;

Line 2196: DBMS_AQ.DEQUEUE(

2192: lv_DequeueOptions.wait := 1;
2193: x_lock_status := G_LOCK_MSG_SUCCESS;
2194: /**
2195: BEGIN
2196: DBMS_AQ.DEQUEUE(
2197: queue_name => G_XDP_SCHEMA||'.'||p_queue_name,
2198: dequeue_options => lv_DequeueOptions,
2199: message_properties => lv_MessageProperties,
2200: payload => x_user_data,

Line 2214: lv_DequeueOptions.dequeue_mode := DBMS_AQ.REMOVE_NODATA;

2210: return;
2211: END;
2212: **/
2213: if NVL(p_remove_flag,'Y') = 'Y' THEN
2214: lv_DequeueOptions.dequeue_mode := DBMS_AQ.REMOVE_NODATA;
2215: DBMS_AQ.DEQUEUE(
2216: queue_name => G_XDP_SCHEMA||'.'||p_queue_name,
2217: dequeue_options => lv_DequeueOptions,
2218: message_properties => lv_MessageProperties,

Line 2215: DBMS_AQ.DEQUEUE(

2211: END;
2212: **/
2213: if NVL(p_remove_flag,'Y') = 'Y' THEN
2214: lv_DequeueOptions.dequeue_mode := DBMS_AQ.REMOVE_NODATA;
2215: DBMS_AQ.DEQUEUE(
2216: queue_name => G_XDP_SCHEMA||'.'||p_queue_name,
2217: dequeue_options => lv_DequeueOptions,
2218: message_properties => lv_MessageProperties,
2219: payload => lv_user_data,