DBA Data[Home] [Help]

APPS.WF_XML dependencies on WF_QUEUE

Line 1927: wf_queue.set_queue_names;

1923: -- Prepare a LOB to contain the payload message.
1924: -- dbms_lob.createTemporary(l_message, TRUE, dbms_lob.SESSION);
1925: l_messageIdx := wf_temp_lob.getLob(g_LOBTable);
1926:
1927: wf_queue.set_queue_names;
1928: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
1929: p_inbound_outbound => 'OUTBOUND',
1930: p_queue_name => l_queue_name);
1931: l_language := l_recipient_list(1).language;

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

1924: -- dbms_lob.createTemporary(l_message, TRUE, dbms_lob.SESSION);
1925: l_messageIdx := wf_temp_lob.getLob(g_LOBTable);
1926:
1927: wf_queue.set_queue_names;
1928: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
1929: p_inbound_outbound => 'OUTBOUND',
1930: p_queue_name => l_queue_name);
1931: l_language := l_recipient_list(1).language;
1932: l_ntf_pref := l_recipient_list(1).notification_preference;

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

1940: -- minimise the number of Queue messages to the number of recipients.
1941: loop
1942: exit when i > l_recipient_list.COUNT;
1943: if l_ntf_pref <> l_recipient_list(i).notification_preference then
1944: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
1945: p_inbound_outbound => 'OUTBOUND',
1946: p_queue_name => l_queue_name);
1947:
1948: end if;

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

1968:
1969: -- Push the message to the queue.
1970: enqueueLOBMessage(p_queue => l_queue_name,
1971: p_priority => l_priority,
1972: p_correlation => wf_queue.account_name ||':'||
1973: to_char(p_nid),
1974: p_message => g_LOBTable(l_messageIdx).temp_lob);
1975:
1976: j := 1;

Line 2039: wf_queue.set_queue_names;

2035: -- Get an encoded payload.
2036: getShortLOBXMLMessage(p_nid, l_priority,
2037: g_LOBTable(l_messageIdx).temp_lob);
2038:
2039: wf_queue.set_queue_names;
2040: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
2041: p_inbound_outbound => 'OUTBOUND',
2042: p_queue_name => l_queue_name);
2043:

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

2036: getShortLOBXMLMessage(p_nid, l_priority,
2037: g_LOBTable(l_messageIdx).temp_lob);
2038:
2039: wf_queue.set_queue_names;
2040: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
2041: p_inbound_outbound => 'OUTBOUND',
2042: p_queue_name => l_queue_name);
2043:
2044: -- Push the message to the queue.

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

2043:
2044: -- Push the message to the queue.
2045: enqueueLOBMessage(p_queue => l_queue_name,
2046: p_priority => l_priority,
2047: p_correlation => wf_queue.account_name ||':'||
2048: to_char(p_nid),
2049: p_message => g_LOBTable(l_messageIdx).temp_lob);
2050: end if;
2051: wf_temp_lob.releaseLob(g_LOBTable, l_messageIdx);

Line 2102: wf_queue.set_queue_names;

2098:
2099: -- Get an encoded payload.
2100: getShortXMLMessage(p_nid, l_priority, l_message);
2101:
2102: wf_queue.set_queue_names;
2103: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
2104: p_inbound_outbound => 'OUTBOUND',
2105: p_queue_name => l_queue_name);
2106:

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

2099: -- Get an encoded payload.
2100: getShortXMLMessage(p_nid, l_priority, l_message);
2101:
2102: wf_queue.set_queue_names;
2103: wf_queue.get_hash_queue_name (p_protocol => 'SMTP',
2104: p_inbound_outbound => 'OUTBOUND',
2105: p_queue_name => l_queue_name);
2106:
2107: -- Push the message to the queue.

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

2106:
2107: -- Push the message to the queue.
2108: enqueueMessage(p_queue => l_queue_name,
2109: p_priority => l_priority,
2110: p_correlation => wf_queue.account_name ||':'||
2111: to_char(p_nid),
2112: p_message => l_message);
2113: end if;
2114:

Line 2333: l_queue_name := wf_queue.enable_exception_queue(

2329: pragma exception_init(no_program_unit, -6508);
2330:
2331: begin
2332:
2333: l_queue_name := wf_queue.enable_exception_queue(
2334: g_wfSchema||
2335: '.WF_SMTP_O_'||to_char(p_queue)||'_QUEUE');
2336: if l_queue_name is not NULL then
2337: GetQueueMessage(l_queue_name, p_nid, p_recipient, p_status,

Line 2533: from wf_queues

2529: begin
2530:
2531: select protocol, inbound_outbound, queue_count
2532: into l_protocol, l_iobound, l_queue_count
2533: from wf_queues
2534: where protocol = 'SMTP'
2535: and INBOUND_OUTBOUND = 'OUTBOUND'
2536: and DISABLE_FLAG = 'N';
2537:

Line 2539: wf_queue.set_queue_names;

2535: and INBOUND_OUTBOUND = 'OUTBOUND'
2536: and DISABLE_FLAG = 'N';
2537:
2538: -- Walk though ALL queue names to hunt for the notifications
2539: wf_queue.set_queue_names;
2540: l_wf_schema := g_wfSchema;
2541: for i in 1..l_queue_count loop
2542: -- Build the queue name from the information we know.
2543: l_queue_name := l_wf_schema||'.WF_'||l_protocol||'_'||

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

2544: substr(l_iobound,1,1)||'_'||to_char(i)||'_QUEUE';
2545: l_timeout := FALSE;
2546: while not l_timeout loop
2547: -- Kill all traces of the message.
2548: RemoveMessage(l_queue_name, wf_queue.account_name||':'||
2549: to_char(p_nid), l_timeout);
2550: end loop;
2551: end loop;
2552: -- Remove the messages from the default Exception queues also

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

2551: end loop;
2552: -- Remove the messages from the default Exception queues also
2553: for i in 1..l_queue_count loop
2554: -- Build the queue name from the information we know.
2555: l_queue_name := wf_queue.enable_exception_queue('WF_'||l_protocol||
2556: '_'||substr(l_iobound,1,1)||'_'||to_char(i)||'_QUEUE');
2557: if l_queue_name is not NULL then
2558: l_timeout := FALSE;
2559: while not l_timeout loop

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

2557: if l_queue_name is not NULL then
2558: l_timeout := FALSE;
2559: while not l_timeout loop
2560: -- Kill all traces of the message.
2561: RemoveMessage(l_queue_name, wf_queue.account_name||':'||
2562: to_char(p_nid), l_timeout);
2563: end loop;
2564: end if;
2565: end loop;