APPS.WF_EVENT dependencies on DBMS_AQ

Line 1056: x_message_properties in out nocopy dbms_aq.message_properties_t) IS

1052: */
1053: PROCEDURE Set_Recipient_List(p_event in wf_event_t,
1054: p_out_agent_name in varchar2,
1055: p_out_system_name in varchar2,
1056: x_message_properties in out nocopy dbms_aq.message_properties_t) IS
1057: l_to_type WF_AGENTS.TYPE%TYPE;
1058: l_to_agent_name WF_AGENTS.NAME%TYPE;
1059: l_to_system_name WF_SYSTEMS.NAME%TYPE;
1060: l_out_queue_handler WF_AGENTS.QUEUE_HANDLER%TYPE;

Line 1326: -- Set the dequeue navigation option to be DBMS_AQ.FIRST_MESSAGE

1322: return;
1323: end if;
1324: end if;
1325:
1326: -- Set the dequeue navigation option to be DBMS_AQ.FIRST_MESSAGE
1327: wf_event.navigation := dbms_aq.first_message;
1328: /*
1329: ** We need to explicitly make sure that if someones Queue Handler
1330: ** blows up we rollback the transaction, just in case they don't

Line 1327: wf_event.navigation := dbms_aq.first_message;

1323: end if;
1324: end if;
1325:
1326: -- Set the dequeue navigation option to be DBMS_AQ.FIRST_MESSAGE
1327: wf_event.navigation := dbms_aq.first_message;
1328: /*
1329: ** We need to explicitly make sure that if someones Queue Handler
1330: ** blows up we rollback the transaction, just in case they don't
1331: */

Line 1590: l_p_wait := dbms_aq.forever ;

1586: --Bug 2505487
1587: --Any -ve number for the parameter p_wait in the forms
1588: --is accepted as wait forever.
1589: if (p_wait < 0) then
1590: l_p_wait := dbms_aq.forever ;
1591: else
1592: l_p_wait := p_wait;
1593: end if;
1594:

Line 1683: -- Set the dequeue navigation option to be DBMS_AQ.FIRST_MESSAGE

1679: if (wf_event.local_system_status = 'DISABLED') then
1680: return;
1681: end if;
1682:
1683: -- Set the dequeue navigation option to be DBMS_AQ.FIRST_MESSAGE
1684: wf_event.navigation := dbms_aq.first_message;
1685: /*
1686: ** We need to explicitly make sure that if someones Queue Handler
1687: ** blows up we rollback the transaction, just in case they don't

Line 1684: wf_event.navigation := dbms_aq.first_message;

1680: return;
1681: end if;
1682:
1683: -- Set the dequeue navigation option to be DBMS_AQ.FIRST_MESSAGE
1684: wf_event.navigation := dbms_aq.first_message;
1685: /*
1686: ** We need to explicitly make sure that if someones Queue Handler
1687: ** blows up we rollback the transaction, just in case they don't
1688: */

Line 1715: wf_event.navigation := dbms_aq.next_transaction;

1711: wf_log_pkg.string(wf_log_pkg.level_event,
1712: 'wf.plsql.WF_EVENT.Listen_GRP.complete',
1713: 'End of the transaction');
1714: end if;
1715: wf_event.navigation := dbms_aq.next_transaction;
1716: commit;
1717:
1718: when others then
1719: wf_event.wf_exception_source := 'QH';

Line 1801: wf_event.navigation := dbms_aq.next_transaction;

1797: 'wf.plsql.WF_EVENT.Listen_GRP.complete',
1798: 'End of the transaction');
1799: end if;
1800:
1801: wf_event.navigation := dbms_aq.next_transaction;
1802: commit;
1803:
1804: when others then
1805: wf_event.wf_exception_source := 'QH';

Line 1832: wf_event.navigation := dbms_aq.next_transaction;

1828: 'wf.plsql.WF_EVENT.Listen_GRP.complete',
1829: 'End of the transaction after dispatch error');
1830: end if;
1831:
1832: wf_event.navigation := dbms_aq.next_transaction;
1833:
1834: end;
1835:
1836: --Rollback the whole transaction, which will update the retry count

Line 1854: if (wf_event.navigation = dbms_aq.first_message) then

1850: when others then
1851: raise;
1852:
1853: end;
1854: if (wf_event.navigation = dbms_aq.first_message) then
1855: exit; --Outer Loop.
1856: --The queue handler must have reached the last message and
1857: --reset the navigation back to the beginning.
1858:

Line 2989: WF_EVENT.navigation := dbms_aq.first_message;

2985: PROCEDURE Set_Correlation(p_correlation in varchar2)
2986: IS
2987: BEGIN
2988: WF_EVENT.g_correlation := p_correlation;
2989: WF_EVENT.navigation := dbms_aq.first_message;
2990: END Set_Correlation;
2991:
2992: ---------------------------------------------------------------------------
2993: /*

Line 3239: DBMS_AQADM.START_QUEUE(wf_event.schema_name||'.'||q_name.name);

3235: --schema := wf_core.translate('WF_SCHEMA');
3236: --Bug 3659756, no longer start fixed name queues.
3237: /*
3238: for q_name in q_disabled (wf_event.schema_name) loop
3239: DBMS_AQADM.START_QUEUE(wf_event.schema_name||'.'||q_name.name);
3240: end loop;
3241: */
3242: -- The agent details must be retrieved even for seeded queue.
3243: GetAgentDetails(agent_name);

Line 3263: DBMS_AQADM.START_QUEUE(wf_event.pv_last_schema_name || '.' || wf_event.pv_last_queue_name, FALSE);

3259: 'starting queue = ' || wf_event.pv_last_schema_name
3260: || '.' || wf_event.pv_last_agent_name);
3261: end if;
3262:
3263: DBMS_AQADM.START_QUEUE(wf_event.pv_last_schema_name || '.' || wf_event.pv_last_queue_name, FALSE);
3264:
3265: WF_EVENT.pv_last_dequeue_enabled := 'YES';
3266: end if;
3267:

Line 3288: -- NOTE: This must be done in PL/SQL because in 8i DBMS_AQ.LISTEN is not

3284: */
3285: FUNCTION Peek_Agent (p_agent_name IN VARCHAR2)
3286: RETURN VARCHAR2
3287: AS
3288: -- NOTE: This must be done in PL/SQL because in 8i DBMS_AQ.LISTEN is not
3289: -- supported in Java
3290:
3291: l_agent sys.aq$_agent;
3292: l_agent_list dbms_aq.aq$_agent_list_t;

Line 3292: l_agent_list dbms_aq.aq$_agent_list_t;

3288: -- NOTE: This must be done in PL/SQL because in 8i DBMS_AQ.LISTEN is not
3289: -- supported in Java
3290:
3291: l_agent sys.aq$_agent;
3292: l_agent_list dbms_aq.aq$_agent_list_t;
3293:
3294: LISTEN_EXCEPTION exception;
3295:
3296: pragma exception_init(LISTEN_EXCEPTION, -25254);

Line 3327: DBMS_AQ.Listen(agent_list => l_agent_list,

3323: END IF;
3324:
3325: -- "Listen" for messages on this queue
3326: BEGIN
3327: DBMS_AQ.Listen(agent_list => l_agent_list,
3328: wait => 0,
3329: agent => l_agent);
3330: EXCEPTION
3331: WHEN LISTEN_EXCEPTION THEN