APPS.WF_EVENT_QH dependencies on WF_EVENT_QH

Line 1: package body WF_EVENT_QH as

1: package body WF_EVENT_QH as
2: /* $Header: wfquhndb.pls 120.3.12020000.4 2013/04/09 17:08:19 skandepu ship $ */
3: ------------------------------------------------------------------------------
4: PROCEDURE dequeue(p_agent_guid in raw,
5: p_event out nocopy wf_event_t,

Line 28: 'wf.plsql.WF_EVENT_QH.dequeue.Begin',

24: where guid = p_agent_guid;
25:
26: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
27: wf_log_pkg.string(wf_log_pkg.level_procedure,
28: 'wf.plsql.WF_EVENT_QH.dequeue.Begin',
29: 'Dequeuing '||x_queue_name||' on '||x_agent_name);
30: end if;
31:
32: -- Set correlation Id for dequeue if only available and not '%'

Line 58: 'wf.plsql.WF_EVENT_QH.dequeue.corr',

54: l_corrId_list := WF_CORE.getDedicatedComponentsCorrIds(x_agent_name, wf_event.account_name);
55:
56: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
57: wf_log_pkg.string(wf_log_pkg.level_statement,
58: 'wf.plsql.WF_EVENT_QH.dequeue.corr',
59: 'The dedicated components correlation ids list is:' || l_corrId_list);
60: end if;
61:
62: x_dequeue_options.correlation := null;

Line 74: 'wf.plsql.WF_EVENT_QH.dequeue.corrid',

70:
71: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
72: if (wf_event.g_correlation is not null) then
73: wf_log_pkg.string(wf_log_pkg.level_procedure,
74: 'wf.plsql.WF_EVENT_QH.dequeue.corrid',
75: 'Dequeuing with Correlation:'|| x_dequeue_options.correlation);
76: else
77: wf_log_pkg.string(wf_log_pkg.level_procedure,
78: 'wf.plsql.WF_EVENT_QH.dequeue.corrid',

Line 78: 'wf.plsql.WF_EVENT_QH.dequeue.corrid',

74: 'wf.plsql.WF_EVENT_QH.dequeue.corrid',
75: 'Dequeuing with Correlation:'|| x_dequeue_options.correlation);
76: else
77: wf_log_pkg.string(wf_log_pkg.level_procedure,
78: 'wf.plsql.WF_EVENT_QH.dequeue.corrid',
79: 'Dequeuing with dequeue condition:'||x_dequeue_options.deq_condition);
80: end if;
81: end if;
82:

Line 113: 'wf.plsql.WF_EVENT_QH.dequeue.queue_empty',

109: EXCEPTION
110: when no_messages then
111: if (wf_log_pkg.level_event >= fnd_log.g_current_runtime_level) then
112: wf_log_pkg.string(wf_log_pkg.level_event,
113: 'wf.plsql.WF_EVENT_QH.dequeue.queue_empty',
114: 'No more messages in dequeue.');
115: end if;
116:
117: -- reset navigation

Line 141: 'wf.plsql.WF_EVENT_QH.dequeue.End',

137: -- Set the Receive Date
138: p_event.SetReceiveDate(sysdate);
139: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
140: wf_log_pkg.string(wf_log_pkg.level_procedure,
141: 'wf.plsql.WF_EVENT_QH.dequeue.End',
142: 'Finished');
143: end if;
144: exception
145: when others then

Line 146: Wf_Core.Context('Wf_Event_QH', 'Dequeue', x_queue_name,

142: 'Finished');
143: end if;
144: exception
145: when others then
146: Wf_Core.Context('Wf_Event_QH', 'Dequeue', x_queue_name,
147: 'SQL err is '||substr(sqlerrm,1,200));
148: raise;
149: end dequeue;
150: ------------------------------------------------------------------------------

Line 228: 'wf.plsql.WF_EVENT_QH.enqueue.delay',

224: */
225: if (p_event.Send_Date > sysdate) then
226: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
227: wf_log_pkg.string(wf_log_pkg.level_statement,
228: 'wf.plsql.WF_EVENT_QH.enqueue.delay',
229: 'Delay Detected');
230: end if;
231:
232: delay := (p_event.Send_Date - sysdate) *24*60*60;

Line 236: 'wf.plsql.WF_EVENT_QH.enqueue.delay_time',

232: delay := (p_event.Send_Date - sysdate) *24*60*60;
233:
234: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
235: wf_log_pkg.string(wf_log_pkg.level_statement,
236: 'wf.plsql.WF_EVENT_QH.enqueue.delay_time',
237: 'Delay ='||to_char(delay));
238: end if;
239:
240: if delay > 1 then

Line 287: 'wf.plsql.WF_EVENT_QH.enqueue.dbms_aq',

283: end if;
284: END IF;
285: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
286: wf_log_pkg.string(wf_log_pkg.level_statement,
287: 'wf.plsql.WF_EVENT_QH.enqueue.dbms_aq',
288: 'calling dbms_aq.enqueue');
289: end if;
290:
291: DBMS_AQ.ENQUEUE(

Line 303: 'wf.plsql.WF_EVENT_QH.enqueue.End',

299: WF_EVENT.g_msgid := x_msgid;
300:
301: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
302: wf_log_pkg.string(wf_log_pkg.level_procedure,
303: 'wf.plsql.WF_EVENT_QH.enqueue.End',
304: 'finished calling dbms_aq.enqueue');
305: end if;
306:
307: exception

Line 309: Wf_Core.Context('Wf_Event_QH', 'Enqueue', x_out_queue,

305: end if;
306:
307: exception
308: when others then
309: Wf_Core.Context('Wf_Event_QH', 'Enqueue', x_out_queue,
310: 'SQL err is '||substr(sqlerrm,1,200));
311: raise;
312: end enqueue;
313: ------------------------------------------------------------------------------

Line 314: end WF_EVENT_QH;

310: 'SQL err is '||substr(sqlerrm,1,200));
311: raise;
312: end enqueue;
313: ------------------------------------------------------------------------------
314: end WF_EVENT_QH;