DBA Data[Home] [Help]

APPS.WF_QUEUE dependencies on WF_EVENT_T

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 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 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 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 */