DBA Data[Home] [Help]

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.1.12000000.2 2007/07/03 04:03:38 sstomar ship $ */
3: ------------------------------------------------------------------------------
4: PROCEDURE dequeue(p_agent_guid in raw,
5: p_event out nocopy wf_event_t,

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

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

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

43:
44: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
45: if (wf_event.g_correlation is not null) then
46: wf_log_pkg.string(wf_log_pkg.level_procedure,
47: 'wf.plsql.WF_EVENT_QH.dequeue.corrid',
48: 'Dequeuing with Correlation ' || x_dequeue_options.correlation);
49: else
50: wf_log_pkg.string(wf_log_pkg.level_procedure,
51: 'wf.plsql.WF_EVENT_QH.dequeue.corrid',

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

47: 'wf.plsql.WF_EVENT_QH.dequeue.corrid',
48: 'Dequeuing with Correlation ' || x_dequeue_options.correlation);
49: else
50: wf_log_pkg.string(wf_log_pkg.level_procedure,
51: 'wf.plsql.WF_EVENT_QH.dequeue.corrid',
52: 'Dequeuing with No Correlation');
53: end if;
54: end if;
55:

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

82: EXCEPTION
83: when no_messages then
84: if (wf_log_pkg.level_event >= fnd_log.g_current_runtime_level) then
85: wf_log_pkg.string(wf_log_pkg.level_event,
86: 'wf.plsql.WF_EVENT_QH.dequeue.queue_empty',
87: 'No more messages in dequeue.');
88: end if;
89:
90: wf_event.navigation := dbms_aq.first_message;

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

120: -- Set the Receive Date
121: p_event.SetReceiveDate(sysdate);
122: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
123: wf_log_pkg.string(wf_log_pkg.level_procedure,
124: 'wf.plsql.WF_EVENT_QH.dequeue.End',
125: 'Finished');
126: end if;
127: exception
128: when others then

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

125: 'Finished');
126: end if;
127: exception
128: when others then
129: Wf_Core.Context('Wf_Event_QH', 'Dequeue', x_queue_name,
130: 'SQL err is '||substr(sqlerrm,1,200));
131: raise;
132: end dequeue;
133: ------------------------------------------------------------------------------

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

207: */
208: if (p_event.Send_Date > sysdate) then
209: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
210: wf_log_pkg.string(wf_log_pkg.level_statement,
211: 'wf.plsql.WF_EVENT_QH.enqueue.delay',
212: 'Delay Detected');
213: end if;
214:
215: delay := (p_event.Send_Date - sysdate) *24*60*60;

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

215: delay := (p_event.Send_Date - sysdate) *24*60*60;
216:
217: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
218: wf_log_pkg.string(wf_log_pkg.level_statement,
219: 'wf.plsql.WF_EVENT_QH.enqueue.delay_time',
220: 'Delay ='||to_char(delay));
221: end if;
222:
223: if delay > 1 then

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

266: end if;
267: END IF;
268: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
269: wf_log_pkg.string(wf_log_pkg.level_statement,
270: 'wf.plsql.WF_EVENT_QH.enqueue.dbms_aq',
271: 'calling dbms_aq.enqueue');
272: end if;
273:
274: DBMS_AQ.ENQUEUE(

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

282: WF_EVENT.g_msgid := x_msgid;
283:
284: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
285: wf_log_pkg.string(wf_log_pkg.level_procedure,
286: 'wf.plsql.WF_EVENT_QH.enqueue.End',
287: 'finished calling dbms_aq.enqueue');
288: end if;
289:
290: exception

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

288: end if;
289:
290: exception
291: when others then
292: Wf_Core.Context('Wf_Event_QH', 'Enqueue', x_out_queue,
293: 'SQL err is '||substr(sqlerrm,1,200));
294: raise;
295: end enqueue;
296: ------------------------------------------------------------------------------

Line 297: end WF_EVENT_QH;

293: 'SQL err is '||substr(sqlerrm,1,200));
294: raise;
295: end enqueue;
296: ------------------------------------------------------------------------------
297: end WF_EVENT_QH;