DBA Data[Home] [Help]

APPS.WF_EVENT dependencies on DBMS_AQ

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

1082: */
1083: PROCEDURE Set_Recipient_List(p_event in wf_event_t,
1084: p_out_agent_name in varchar2,
1085: p_out_system_name in varchar2,
1086: x_message_properties in out nocopy dbms_aq.message_properties_t) IS
1087: l_to_type WF_AGENTS.TYPE%TYPE;
1088: l_to_agent_name WF_AGENTS.NAME%TYPE;
1089: l_to_system_name WF_SYSTEMS.NAME%TYPE;
1090: l_out_queue_handler WF_AGENTS.QUEUE_HANDLER%TYPE;

Line 1631: l_p_wait := dbms_aq.forever ;

1627: --Bug 2505487
1628: --Any -ve number for the parameter p_wait in the forms
1629: --is accepted as wait forever.
1630: if (p_wait < 0) then
1631: l_p_wait := dbms_aq.forever ;
1632: else
1633: l_p_wait := p_wait;
1634: end if;
1635:

Line 1905: -- otherwise, condition is wf_event.navigation = dbms_aq.first_message

1901:
1902: -- if QH is using setNavigationParams/getQueueNavigation, condition is
1903: -- g_processedMessagesCount = 0 and g_currentNavigation either
1904: -- FIRST_MESSAGE or NEXT_TRANSACTION,
1905: -- otherwise, condition is wf_event.navigation = dbms_aq.first_message
1906: if (g_navResetThreshold is not null and g_processedMessagesCount = 0
1907: and (g_currentNavigation in (dbms_aq.FIRST_MESSAGE, dbms_aq.NEXT_TRANSACTION)))
1908: OR
1909: (g_navResetThreshold is null and wf_event.navigation = dbms_aq.first_message)

Line 1907: and (g_currentNavigation in (dbms_aq.FIRST_MESSAGE, dbms_aq.NEXT_TRANSACTION)))

1903: -- g_processedMessagesCount = 0 and g_currentNavigation either
1904: -- FIRST_MESSAGE or NEXT_TRANSACTION,
1905: -- otherwise, condition is wf_event.navigation = dbms_aq.first_message
1906: if (g_navResetThreshold is not null and g_processedMessagesCount = 0
1907: and (g_currentNavigation in (dbms_aq.FIRST_MESSAGE, dbms_aq.NEXT_TRANSACTION)))
1908: OR
1909: (g_navResetThreshold is null and wf_event.navigation = dbms_aq.first_message)
1910: then
1911:

Line 1909: (g_navResetThreshold is null and wf_event.navigation = dbms_aq.first_message)

1905: -- otherwise, condition is wf_event.navigation = dbms_aq.first_message
1906: if (g_navResetThreshold is not null and g_processedMessagesCount = 0
1907: and (g_currentNavigation in (dbms_aq.FIRST_MESSAGE, dbms_aq.NEXT_TRANSACTION)))
1908: OR
1909: (g_navResetThreshold is null and wf_event.navigation = dbms_aq.first_message)
1910: then
1911:
1912: exit; --Outer Loop.
1913: --The queue handler must have reached the last message and

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

3046: PROCEDURE Set_Correlation(p_correlation in varchar2)
3047: IS
3048: BEGIN
3049: WF_EVENT.g_correlation := p_correlation;
3050: WF_EVENT.navigation := dbms_aq.first_message;
3051:
3052: END Set_Correlation;
3053:
3054: ---------------------------------------------------------------------------

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

3297: --schema := wf_core.translate('WF_SCHEMA');
3298: --Bug 3659756, no longer start fixed name queues.
3299: /*
3300: for q_name in q_disabled (wf_event.schema_name) loop
3301: DBMS_AQADM.START_QUEUE(wf_event.schema_name||'.'||q_name.name);
3302: end loop;
3303: */
3304: -- The agent details must be retrieved even for seeded queue.
3305: GetAgentDetails(agent_name);

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

3321: 'starting queue = ' || wf_event.pv_last_schema_name
3322: || '.' || wf_event.pv_last_agent_name);
3323: end if;
3324:
3325: DBMS_AQADM.START_QUEUE(wf_event.pv_last_schema_name || '.' || wf_event.pv_last_queue_name, FALSE);
3326:
3327: WF_EVENT.pv_last_dequeue_enabled := 'YES';
3328: end if;
3329:

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

3346: */
3347: FUNCTION Peek_Agent (p_agent_name IN VARCHAR2)
3348: RETURN VARCHAR2
3349: AS
3350: -- NOTE: This must be done in PL/SQL because in 8i DBMS_AQ.LISTEN is not
3351: -- supported in Java
3352:
3353: l_agent sys.aq$_agent;
3354: l_agent_list dbms_aq.aq$_agent_list_t;

Line 3354: l_agent_list dbms_aq.aq$_agent_list_t;

3350: -- NOTE: This must be done in PL/SQL because in 8i DBMS_AQ.LISTEN is not
3351: -- supported in Java
3352:
3353: l_agent sys.aq$_agent;
3354: l_agent_list dbms_aq.aq$_agent_list_t;
3355:
3356: LISTEN_EXCEPTION exception;
3357:
3358: pragma exception_init(LISTEN_EXCEPTION, -25254);

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

3385: END IF;
3386:
3387: -- "Listen" for messages on this queue
3388: BEGIN
3389: DBMS_AQ.Listen(agent_list => l_agent_list,
3390: wait => 0,
3391: agent => l_agent);
3392: EXCEPTION
3393: WHEN LISTEN_EXCEPTION THEN

Line 3478: elsif g_currentNavigation= dbms_aq.NEXT_MESSAGE then

3474: l_ret varchar2(1000):= 'navigation(';
3475: begin
3476: if (g_currentNavigation is null) then
3477: l_ret:= l_ret|| 'null), ';
3478: elsif g_currentNavigation= dbms_aq.NEXT_MESSAGE then
3479: l_ret:= l_ret|| 'NEXT_MESSAGE), ';
3480: elsif g_currentNavigation= dbms_aq.FIRST_MESSAGE then
3481: l_ret:= l_ret|| 'FIRST_MESSAGE), ';
3482: elsif g_currentNavigation= dbms_aq.NEXT_TRANSACTION then

Line 3480: elsif g_currentNavigation= dbms_aq.FIRST_MESSAGE then

3476: if (g_currentNavigation is null) then
3477: l_ret:= l_ret|| 'null), ';
3478: elsif g_currentNavigation= dbms_aq.NEXT_MESSAGE then
3479: l_ret:= l_ret|| 'NEXT_MESSAGE), ';
3480: elsif g_currentNavigation= dbms_aq.FIRST_MESSAGE then
3481: l_ret:= l_ret|| 'FIRST_MESSAGE), ';
3482: elsif g_currentNavigation= dbms_aq.NEXT_TRANSACTION then
3483: l_ret:= l_ret|| 'NEXT_TRANSACTION), ';
3484: else

Line 3482: elsif g_currentNavigation= dbms_aq.NEXT_TRANSACTION then

3478: elsif g_currentNavigation= dbms_aq.NEXT_MESSAGE then
3479: l_ret:= l_ret|| 'NEXT_MESSAGE), ';
3480: elsif g_currentNavigation= dbms_aq.FIRST_MESSAGE then
3481: l_ret:= l_ret|| 'FIRST_MESSAGE), ';
3482: elsif g_currentNavigation= dbms_aq.NEXT_TRANSACTION then
3483: l_ret:= l_ret|| 'NEXT_TRANSACTION), ';
3484: else
3485: l_ret:= l_ret|| g_currentNavigation||'), ';
3486: end if;

Line 3569: l_ret := dbms_aq.FIRST_MESSAGE;

3565: -- If navigation params are not initialized, return FIRST_MESSAGE
3566: -- else return NEXT_MESSAGE
3567: if ( g_processedMessagesCount = 0 ) then
3568: if (g_currentNavigation is null) then
3569: l_ret := dbms_aq.FIRST_MESSAGE;
3570: else
3571: l_ret := dbms_aq.NEXT_TRANSACTION;
3572: end if;
3573: else

Line 3571: l_ret := dbms_aq.NEXT_TRANSACTION;

3567: if ( g_processedMessagesCount = 0 ) then
3568: if (g_currentNavigation is null) then
3569: l_ret := dbms_aq.FIRST_MESSAGE;
3570: else
3571: l_ret := dbms_aq.NEXT_TRANSACTION;
3572: end if;
3573: else
3574: l_ret := dbms_aq.NEXT_MESSAGE;
3575: end if;

Line 3574: l_ret := dbms_aq.NEXT_MESSAGE;

3570: else
3571: l_ret := dbms_aq.NEXT_TRANSACTION;
3572: end if;
3573: else
3574: l_ret := dbms_aq.NEXT_MESSAGE;
3575: end if;
3576: else -- no TRANSACTIONAL navigation, threshold logic applies
3577:
3578: -- If first call (g_processedMessagesCount = 0), or if threshold is

Line 3586: l_ret := dbms_aq.FIRST_MESSAGE;

3582: (g_navResetThreshold >0 and
3583: g_ProcessedMessagesCount >= g_navResetThreshold)
3584: then
3585: g_processedMessagesCount := 0; -- reset counter, if threshold is reached
3586: l_ret := dbms_aq.FIRST_MESSAGE;
3587: else
3588: l_ret := dbms_aq.NEXT_MESSAGE;
3589: end if;
3590: end if;

Line 3588: l_ret := dbms_aq.NEXT_MESSAGE;

3584: then
3585: g_processedMessagesCount := 0; -- reset counter, if threshold is reached
3586: l_ret := dbms_aq.FIRST_MESSAGE;
3587: else
3588: l_ret := dbms_aq.NEXT_MESSAGE;
3589: end if;
3590: end if;
3591:
3592: g_processedMessagesCount := g_processedMessagesCount + 1;