DBA Data[Home] [Help]

APPS.WF_XML dependencies on WF_QUEUE

Line 1856: wf_queue.set_queue_names;

1852: -- Prepare a LOB to contain the payload message.
1853: -- dbms_lob.createTemporary(l_message, TRUE, dbms_lob.SESSION);
1854: l_messageIdx := wf_temp_lob.getLob(g_LOBTable);
1855:
1856: wf_queue.set_queue_names;
1857: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
1858: p_inbound_outbound => 'OUTBOUND',
1859: p_queue_name => l_queue_name);
1860: l_language := l_recipient_list(1).language;

Line 1857: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',

1853: -- dbms_lob.createTemporary(l_message, TRUE, dbms_lob.SESSION);
1854: l_messageIdx := wf_temp_lob.getLob(g_LOBTable);
1855:
1856: wf_queue.set_queue_names;
1857: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
1858: p_inbound_outbound => 'OUTBOUND',
1859: p_queue_name => l_queue_name);
1860: l_language := l_recipient_list(1).language;
1861: l_ntf_pref := l_recipient_list(1).notification_preference;

Line 1873: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',

1869: -- minimise the number of Queue messages to the number of recipients.
1870: loop
1871: exit when i > l_recipient_list.COUNT;
1872: if l_ntf_pref <> l_recipient_list(i).notification_preference then
1873: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
1874: p_inbound_outbound => 'OUTBOUND',
1875: p_queue_name => l_queue_name);
1876:
1877: end if;

Line 1901: p_correlation => wf_queue.account_name ||':'||

1897:
1898: -- Push the message to the queue.
1899: enqueueLOBMessage(p_queue => l_queue_name,
1900: p_priority => l_priority,
1901: p_correlation => wf_queue.account_name ||':'||
1902: to_char(p_nid),
1903: p_message => g_LOBTable(l_messageIdx).temp_lob);
1904:
1905: j := 1;

Line 1968: wf_queue.set_queue_names;

1964: -- Get an encoded payload.
1965: getShortLOBXMLMessage(p_nid, l_priority,
1966: g_LOBTable(l_messageIdx).temp_lob);
1967:
1968: wf_queue.set_queue_names;
1969: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
1970: p_inbound_outbound => 'OUTBOUND',
1971: p_queue_name => l_queue_name);
1972:

Line 1969: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',

1965: getShortLOBXMLMessage(p_nid, l_priority,
1966: g_LOBTable(l_messageIdx).temp_lob);
1967:
1968: wf_queue.set_queue_names;
1969: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
1970: p_inbound_outbound => 'OUTBOUND',
1971: p_queue_name => l_queue_name);
1972:
1973: -- Push the message to the queue.

Line 1976: p_correlation => wf_queue.account_name ||':'||

1972:
1973: -- Push the message to the queue.
1974: enqueueLOBMessage(p_queue => l_queue_name,
1975: p_priority => l_priority,
1976: p_correlation => wf_queue.account_name ||':'||
1977: to_char(p_nid),
1978: p_message => g_LOBTable(l_messageIdx).temp_lob);
1979: end if;
1980: wf_temp_lob.releaseLob(g_LOBTable, l_messageIdx);

Line 2031: wf_queue.set_queue_names;

2027:
2028: -- Get an encoded payload.
2029: getShortXMLMessage(p_nid, l_priority, l_message);
2030:
2031: wf_queue.set_queue_names;
2032: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
2033: p_inbound_outbound => 'OUTBOUND',
2034: p_queue_name => l_queue_name);
2035:

Line 2032: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',

2028: -- Get an encoded payload.
2029: getShortXMLMessage(p_nid, l_priority, l_message);
2030:
2031: wf_queue.set_queue_names;
2032: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
2033: p_inbound_outbound => 'OUTBOUND',
2034: p_queue_name => l_queue_name);
2035:
2036: -- Push the message to the queue.

Line 2039: p_correlation => wf_queue.account_name ||':'||

2035:
2036: -- Push the message to the queue.
2037: enqueueMessage(p_queue => l_queue_name,
2038: p_priority => l_priority,
2039: p_correlation => wf_queue.account_name ||':'||
2040: to_char(p_nid),
2041: p_message => l_message);
2042: end if;
2043:

Line 2262: l_queue_name := wf_queue.enable_exception_queue(

2258: pragma exception_init(no_program_unit, -6508);
2259:
2260: begin
2261:
2262: l_queue_name := wf_queue.enable_exception_queue(
2263: g_wfSchema||
2264: '.WF_SMTP_O_'||to_char(p_queue)||'_QUEUE');
2265: if l_queue_name is not NULL then
2266: GetQueueMessage(l_queue_name, p_nid, p_recipient, p_status,

Line 2462: from wf_queues

2458: begin
2459:
2460: select protocol, inbound_outbound, queue_count
2461: into l_protocol, l_iobound, l_queue_count
2462: from wf_queues
2463: where protocol = 'SMTP'
2464: and INBOUND_OUTBOUND = 'OUTBOUND'
2465: and DISABLE_FLAG = 'N';
2466:

Line 2468: wf_queue.set_queue_names;

2464: and INBOUND_OUTBOUND = 'OUTBOUND'
2465: and DISABLE_FLAG = 'N';
2466:
2467: -- Walk though ALL queue names to hunt for the notifications
2468: wf_queue.set_queue_names;
2469: l_wf_schema := g_wfSchema;
2470: for i in 1..l_queue_count loop
2471: -- Build the queue name from the information we know.
2472: l_queue_name := l_wf_schema||'.WF_'||l_protocol||'_'||

Line 2477: RemoveMessage(l_queue_name, wf_queue.account_name||':'||

2473: substr(l_iobound,1,1)||'_'||to_char(i)||'_QUEUE';
2474: l_timeout := FALSE;
2475: while not l_timeout loop
2476: -- Kill all traces of the message.
2477: RemoveMessage(l_queue_name, wf_queue.account_name||':'||
2478: to_char(p_nid), l_timeout);
2479: end loop;
2480: end loop;
2481: -- Remove the messages from the default Exception queues also

Line 2484: l_queue_name := wf_queue.enable_exception_queue('WF_'||l_protocol||

2480: end loop;
2481: -- Remove the messages from the default Exception queues also
2482: for i in 1..l_queue_count loop
2483: -- Build the queue name from the information we know.
2484: l_queue_name := wf_queue.enable_exception_queue('WF_'||l_protocol||
2485: '_'||substr(l_iobound,1,1)||'_'||to_char(i)||'_QUEUE');
2486: if l_queue_name is not NULL then
2487: l_timeout := FALSE;
2488: while not l_timeout loop

Line 2490: RemoveMessage(l_queue_name, wf_queue.account_name||':'||

2486: if l_queue_name is not NULL then
2487: l_timeout := FALSE;
2488: while not l_timeout loop
2489: -- Kill all traces of the message.
2490: RemoveMessage(l_queue_name, wf_queue.account_name||':'||
2491: to_char(p_nid), l_timeout);
2492: end loop;
2493: end if;
2494: end loop;