APPS.WFJ_QUEUE dependencies on WFJ_QUEUE

Line 1: package body WFJ_QUEUE as

1: package body WFJ_QUEUE as
2: /* $Header: wfjqueb.pls 120.1 2005/07/02 02:47:52 appldev noship $ */
3:
4: --
5: -- Exceptions

Line 86: lDequeue_options.wait := wfj_queue.dequeueDelay;

82: lCorrelation := wf_queue.account_name||nvl(pItemType,'%');
83: end if;
84: lDequeue_options.correlation := lCorrelation;
85: lDequeue_options.dequeue_mode := pDequeueMode;
86: lDequeue_options.wait := wfj_queue.dequeueDelay;
87: lDequeue_options.navigation := pNavigation;
88:
89: lMessageHandle := hextoraw(pMessageHandle);
90: dbms_aq.dequeue

Line 234: Wf_Core.Context('Wfj_Queue', 'ApplyTransformation', itemtype, itemkey,

230:
231: return(lRowid);
232: exception
233: when no_data_found then
234: Wf_Core.Context('Wfj_Queue', 'ApplyTransformation', itemtype, itemkey,
235: srcName, dstName);
236: Wf_Core.Token('TYPE', itemtype);
237: Wf_Core.Token('KEY', itemkey);
238: Wf_Core.Token('ATTRIBUTE', srcName);

Line 242: Wf_Core.Context('Wfj_Queue', 'ApplyTransformation', itemtype,

238: Wf_Core.Token('ATTRIBUTE', srcName);
239: Wf_Core.Token('ATTRIBUTE', dstName);
240: Wf_Core.Raise('WFENG_ITEM_ATTR');
241: when others then
242: Wf_Core.Context('Wfj_Queue', 'ApplyTransformation', itemtype,
243: itemkey, srcName, dstName);
244: raise;
245: end ApplyTransformation;
246:

Line 254: wfj_queue.dequeueDelay := pDelay;

250: -- pDelay - The number of seconds the dequeue operation should block for
251: procedure setDequeueDelay(pDelay in INTEGER)
252: is
253: begin
254: wfj_queue.dequeueDelay := pDelay;
255: end;
256:
257: -- ====================================================================
258: -- NAME: getDequeueDelay

Line 263: return wfj_queue.dequeueDelay;

259: -- Provides a wrapper for the dequeueDelay spec variable
260: function getDequeueDelay return integer
261: is
262: begin
263: return wfj_queue.dequeueDelay;
264: end;
265:
266: end WFJ_QUEUE;

Line 266: end WFJ_QUEUE;

262: begin
263: return wfj_queue.dequeueDelay;
264: end;
265:
266: end WFJ_QUEUE;