DBA Data[Home] [Help]

APPS.WF_QUEUE dependencies on WF_EVENT

Line 1383: l_event wf_event_t;

1379: --=============================================================
1380: procedure DequeueException (queuename in varchar2)
1381: is
1382:
1383: l_event wf_event_t;
1384: x_dequeue_options dbms_aq.dequeue_options_t;
1385: x_message_properties dbms_aq.message_properties_t;
1386: x_msgid RAW(16);
1387: erragt wf_agent_t;

Line 3109: -- of the given agent. Handles wf_event_t and JMS_TEXT_MESSAGE payloads.

3105:
3106: --
3107: -- move_msgs_excep2normal (CONCURRENT PROGRAM API)
3108: -- API to move messages from the exception queue to the normal queue
3109: -- of the given agent. Handles wf_event_t and JMS_TEXT_MESSAGE payloads.
3110: --
3111: -- OUT
3112: -- errbuf - CP error message
3113: -- retcode - CP return code (0 = success, 1 = warning, 2 = error)

Line 3133: l_payload_evt wf_event_t;

3129: l_timeout integer;
3130: l_dequeue_options dbms_aq.dequeue_options_t;
3131: l_enqueue_options dbms_aq.enqueue_options_t;
3132: l_message_properties dbms_aq.message_properties_t;
3133: l_payload_evt wf_event_t;
3134: l_payload_jms sys.aq$_JMS_TEXT_MESSAGE;
3135: l_msg_id raw(16);
3136: invalid_agent exception;
3137: invalid_type exception;

Line 3148: AND SYSTEM_GUID = wf_event.local_system_guid;

3144: SELECT TRIM(queue_name), TRIM(queue_handler)
3145: INTO l_queue_name, l_queue_handler
3146: FROM wf_agents
3147: WHERE name = upper(p_agent_name)
3148: AND SYSTEM_GUID = wf_event.local_system_guid;
3149: exception
3150: when no_data_found then
3151: raise_application_error(-20201, 'Agent not found');
3152: when others then

Line 3182: if l_obj_type = 'WF_EVENT_T' then

3178: l_dequeue_options.wait := dbms_aq.NO_WAIT;
3179: l_dequeue_options.consumer_name := null;
3180: l_enqueue_options.visibility := dbms_aq.ON_COMMIT;
3181:
3182: if l_obj_type = 'WF_EVENT_T' then
3183: wf_event_t.Initialize(l_payload_evt);
3184: while (l_timeout = 0) loop
3185: begin
3186: --Dequeue the message from the exception queue

Line 3183: wf_event_t.Initialize(l_payload_evt);

3179: l_dequeue_options.consumer_name := null;
3180: l_enqueue_options.visibility := dbms_aq.ON_COMMIT;
3181:
3182: if l_obj_type = 'WF_EVENT_T' then
3183: wf_event_t.Initialize(l_payload_evt);
3184: while (l_timeout = 0) loop
3185: begin
3186: --Dequeue the message from the exception queue
3187: dbms_aq.Dequeue(queue_name => l_schema || '.' || l_excp_qname,

Line 3214: end loop; --End of while loop that handles wf_event_t payload

3210: l_timeout := 1;
3211: when others then
3212: raise;
3213: end;
3214: end loop; --End of while loop that handles wf_event_t payload
3215:
3216: elsif l_obj_type = 'AQ$_JMS_TEXT_MESSAGE' then
3217: l_timeout := 0;
3218: while (l_timeout = 0) loop

Line 3270: -- of WF_EVENT_T or AQ$_JMS_TEXT_MESSAGE payload type. Supports correlation id based purge.

3266: -- Overloaded Procedure 1 : Definition without the AGE parameter
3267: --
3268: -- clean_evt
3269: -- Procedure to purge the messages in the READY state of a Queue
3270: -- of WF_EVENT_T or AQ$_JMS_TEXT_MESSAGE payload type. Supports correlation id based purge.
3271: --
3272: -- IN
3273: -- p_agent_name - Agent Name
3274: -- p_correlation - Correlation ID (Default Value : NULL)

Line 3292: l_payload wf_event_t;

3288: l_schema varchar2(80);
3289: l_qname varchar2(80);
3290: l_queue_name varchar2(80);
3291: l_account_name varchar2(30);
3292: l_payload wf_event_t;
3293: l_msgid raw(16);
3294: l_message_handle raw(16) := NULL;
3295: l_dequeue_options dbms_aq.dequeue_options_t;
3296: l_message_properties dbms_aq.message_properties_t;

Line 3315: AND SYSTEM_GUID = wf_event.local_system_guid;

3311: SELECT queue_name
3312: INTO l_queue_name
3313: FROM wf_agents
3314: WHERE name = upper(p_agent_name)
3315: AND SYSTEM_GUID = wf_event.local_system_guid;
3316:
3317: l_pos := instr(l_queue_name, '.', 1, 1);
3318: l_schema := substr(l_queue_name, 1, l_pos-1);
3319: l_qname := substr(l_queue_name, l_pos+1);

Line 3349: if (wf_event.account_name is null) then

3345: --Account Name before the Correlation ID
3346: if ((p_correlation is not null) or (p_correlation <> '')) then
3347: -- Seeded WF agents
3348: if (upper(p_agent_name) like 'WF_%') then
3349: if (wf_event.account_name is null) then
3350: wf_event.SetAccountName;
3351: end if;
3352: l_dequeue_options.correlation := wf_event.account_name
3353: || ':'

Line 3350: wf_event.SetAccountName;

3346: if ((p_correlation is not null) or (p_correlation <> '')) then
3347: -- Seeded WF agents
3348: if (upper(p_agent_name) like 'WF_%') then
3349: if (wf_event.account_name is null) then
3350: wf_event.SetAccountName;
3351: end if;
3352: l_dequeue_options.correlation := wf_event.account_name
3353: || ':'
3354: || p_correlation;

Line 3352: l_dequeue_options.correlation := wf_event.account_name

3348: if (upper(p_agent_name) like 'WF_%') then
3349: if (wf_event.account_name is null) then
3350: wf_event.SetAccountName;
3351: end if;
3352: l_dequeue_options.correlation := wf_event.account_name
3353: || ':'
3354: || p_correlation;
3355: else
3356: l_dequeue_options.correlation := p_correlation;

Line 3366: if (l_data_type = 'WF_EVENT_T') then

3362: -- The dequeue is based on the given correlation id
3363: while (l_timeout = 0) loop
3364: begin
3365:
3366: if (l_data_type = 'WF_EVENT_T') then
3367: dbms_aq.Dequeue(queue_name => l_queue_name,
3368: dequeue_options => l_dequeue_options,
3369: message_properties => l_message_properties, /* OUT */
3370: payload => l_payload, /* OUT */

Line 3402: if (l_data_type = 'WF_EVENT_T') then

3398: raise;
3399: else
3400: l_dequeue_options.navigation := dbms_aq.FIRST_MESSAGE;
3401:
3402: if (l_data_type = 'WF_EVENT_T') then
3403: dbms_aq.Dequeue(queue_name => l_queue_name,
3404: dequeue_options => l_dequeue_options,
3405: message_properties => l_message_properties, /* OUT */
3406: payload => l_payload, /* OUT */

Line 3452: -- of WF_EVENT_T or AQ$_JMS_TEXT_MESSAGE payload type. Supports time-based selective

3448: -- Overloaded Procedure 2 : Definition with the AGE parameter
3449: --
3450: -- clean_evt
3451: -- Procedure to purge the messages in the READY state of a Queue
3452: -- of WF_EVENT_T or AQ$_JMS_TEXT_MESSAGE payload type. Supports time-based selective
3453: -- purge with correlation id.
3454: --
3455: -- IN
3456: -- p_agent_name - Agent Name

Line 3478: l_payload wf_event_t;

3474: l_qname varchar2(80);
3475: l_corrid varchar2(128);
3476: l_queue_name varchar2(80);
3477: l_account_name varchar2(30);
3478: l_payload wf_event_t;
3479: l_msgid raw(16);
3480: l_message_handle raw(16) := NULL;
3481: l_dequeue_options dbms_aq.dequeue_options_t;
3482: l_message_properties dbms_aq.message_properties_t;

Line 3503: AND SYSTEM_GUID = wf_event.local_system_guid;

3499: SELECT queue_name
3500: INTO l_queue_name
3501: FROM wf_agents
3502: WHERE name = upper(p_agent_name)
3503: AND SYSTEM_GUID = wf_event.local_system_guid;
3504:
3505: l_pos := instr(l_queue_name, '.', 1, 1);
3506: l_schema := substr(l_queue_name, 1, l_pos-1);
3507: l_qname := substr(l_queue_name, l_pos+1);

Line 3543: if (wf_event.account_name is null) then

3539: --
3540: if ((p_correlation is not null) or (p_correlation <> '')) then
3541: -- Seeded WF agents
3542: if (upper(p_agent_name) like 'WF_%') then
3543: if (wf_event.account_name is null) then
3544: wf_event.SetAccountName;
3545: end if;
3546: l_corrid := wf_event.account_name
3547: || ':'

Line 3544: wf_event.SetAccountName;

3540: if ((p_correlation is not null) or (p_correlation <> '')) then
3541: -- Seeded WF agents
3542: if (upper(p_agent_name) like 'WF_%') then
3543: if (wf_event.account_name is null) then
3544: wf_event.SetAccountName;
3545: end if;
3546: l_corrid := wf_event.account_name
3547: || ':'
3548: || p_correlation;

Line 3546: l_corrid := wf_event.account_name

3542: if (upper(p_agent_name) like 'WF_%') then
3543: if (wf_event.account_name is null) then
3544: wf_event.SetAccountName;
3545: end if;
3546: l_corrid := wf_event.account_name
3547: || ':'
3548: || p_correlation;
3549: else
3550: l_corrid := p_correlation;

Line 3579: if (l_data_type = 'WF_EVENT_T') then

3575: exit when c_msgs%notfound;
3576: l_dequeue_options.msgid := l_msgid;
3577: begin
3578:
3579: if (l_data_type = 'WF_EVENT_T') then
3580: dbms_aq.Dequeue(queue_name => l_queue_name,
3581: dequeue_options => l_dequeue_options,
3582: message_properties => l_message_properties,
3583: payload => l_payload,

Line 3611: if (l_data_type = 'WF_EVENT_T') then

3607: raise;
3608: else
3609: l_dequeue_options.navigation := dbms_aq.FIRST_MESSAGE;
3610:
3611: if (l_data_type = 'WF_EVENT_T') then
3612: dbms_aq.Dequeue(queue_name => l_queue_name,
3613: dequeue_options => l_dequeue_options,
3614: message_properties => l_message_properties, /* OUT */
3615: payload => l_payload, /* OUT */