[Home] [Help]
1359: --=============================================================
1360: procedure DequeueException (queuename in varchar2)
1361: is
1362:
1363: l_event wf_event_t;
1364: x_dequeue_options dbms_aq.dequeue_options_t;
1365: x_message_properties dbms_aq.message_properties_t;
1366: x_msgid RAW(16);
1367: erragt wf_agent_t;
3085:
3086: --
3087: -- move_msgs_excep2normal (CONCURRENT PROGRAM API)
3088: -- API to move messages from the exception queue to the normal queue
3089: -- of the given agent. Handles wf_event_t and JMS_TEXT_MESSAGE payloads.
3090: --
3091: -- OUT
3092: -- errbuf - CP error message
3093: -- retcode - CP return code (0 = success, 1 = warning, 2 = error)
3109: l_timeout integer;
3110: l_dequeue_options dbms_aq.dequeue_options_t;
3111: l_enqueue_options dbms_aq.enqueue_options_t;
3112: l_message_properties dbms_aq.message_properties_t;
3113: l_payload_evt wf_event_t;
3114: l_payload_jms sys.aq$_JMS_TEXT_MESSAGE;
3115: l_msg_id raw(16);
3116: invalid_agent exception;
3117: invalid_type exception;
3124: SELECT TRIM(queue_name), TRIM(queue_handler)
3125: INTO l_queue_name, l_queue_handler
3126: FROM wf_agents
3127: WHERE name = upper(p_agent_name)
3128: AND SYSTEM_GUID = wf_event.local_system_guid;
3129: exception
3130: when no_data_found then
3131: raise_application_error(-20201, 'Agent not found');
3132: when others then
3158: l_dequeue_options.wait := dbms_aq.NO_WAIT;
3159: l_dequeue_options.consumer_name := null;
3160: l_enqueue_options.visibility := dbms_aq.ON_COMMIT;
3161:
3162: if l_obj_type = 'WF_EVENT_T' then
3163: wf_event_t.Initialize(l_payload_evt);
3164: while (l_timeout = 0) loop
3165: begin
3166: --Dequeue the message from the exception queue
3159: l_dequeue_options.consumer_name := null;
3160: l_enqueue_options.visibility := dbms_aq.ON_COMMIT;
3161:
3162: if l_obj_type = 'WF_EVENT_T' then
3163: wf_event_t.Initialize(l_payload_evt);
3164: while (l_timeout = 0) loop
3165: begin
3166: --Dequeue the message from the exception queue
3167: dbms_aq.Dequeue(queue_name => l_schema || '.' || l_excp_qname,
3190: l_timeout := 1;
3191: when others then
3192: raise;
3193: end;
3194: end loop; --End of while loop that handles wf_event_t payload
3195:
3196: elsif l_obj_type = 'AQ$_JMS_TEXT_MESSAGE' then
3197: l_timeout := 0;
3198: while (l_timeout = 0) loop
3246: -- Overloaded Procedure 1 : Definition without the AGE parameter
3247: --
3248: -- clean_evt
3249: -- Procedure to purge the messages in the READY state of a Queue
3250: -- of WF_EVENT_T or AQ$_JMS_TEXT_MESSAGE payload type. Supports correlation id based purge.
3251: --
3252: -- IN
3253: -- p_agent_name - Agent Name
3254: -- p_correlation - Correlation ID (Default Value : NULL)
3268: l_schema varchar2(80);
3269: l_qname varchar2(80);
3270: l_queue_name varchar2(80);
3271: l_account_name varchar2(30);
3272: l_payload wf_event_t;
3273: l_msgid raw(16);
3274: l_message_handle raw(16) := NULL;
3275: l_dequeue_options dbms_aq.dequeue_options_t;
3276: l_message_properties dbms_aq.message_properties_t;
3291: SELECT queue_name
3292: INTO l_queue_name
3293: FROM wf_agents
3294: WHERE name = upper(p_agent_name)
3295: AND SYSTEM_GUID = wf_event.local_system_guid;
3296:
3297: l_pos := instr(l_queue_name, '.', 1, 1);
3298: l_schema := substr(l_queue_name, 1, l_pos-1);
3299: l_qname := substr(l_queue_name, l_pos+1);
3325: --Account Name before the Correlation ID
3326: if ((p_correlation is not null) or (p_correlation <> '')) then
3327: -- Seeded WF agents
3328: if (upper(p_agent_name) like 'WF_%') then
3329: if (wf_event.account_name is null) then
3330: wf_event.SetAccountName;
3331: end if;
3332: l_dequeue_options.correlation := wf_event.account_name
3333: || ':'
3326: if ((p_correlation is not null) or (p_correlation <> '')) then
3327: -- Seeded WF agents
3328: if (upper(p_agent_name) like 'WF_%') then
3329: if (wf_event.account_name is null) then
3330: wf_event.SetAccountName;
3331: end if;
3332: l_dequeue_options.correlation := wf_event.account_name
3333: || ':'
3334: || p_correlation;
3328: if (upper(p_agent_name) like 'WF_%') then
3329: if (wf_event.account_name is null) then
3330: wf_event.SetAccountName;
3331: end if;
3332: l_dequeue_options.correlation := wf_event.account_name
3333: || ':'
3334: || p_correlation;
3335: else
3336: l_dequeue_options.correlation := p_correlation;
3342: -- The dequeue is based on the given correlation id
3343: while (l_timeout = 0) loop
3344: begin
3345:
3346: if (l_data_type = 'WF_EVENT_T') then
3347: dbms_aq.Dequeue(queue_name => l_queue_name,
3348: dequeue_options => l_dequeue_options,
3349: message_properties => l_message_properties, /* OUT */
3350: payload => l_payload, /* OUT */
3378: raise;
3379: else
3380: l_dequeue_options.navigation := dbms_aq.FIRST_MESSAGE;
3381:
3382: if (l_data_type = 'WF_EVENT_T') then
3383: dbms_aq.Dequeue(queue_name => l_queue_name,
3384: dequeue_options => l_dequeue_options,
3385: message_properties => l_message_properties, /* OUT */
3386: payload => l_payload, /* OUT */
3428: -- Overloaded Procedure 2 : Definition with the AGE parameter
3429: --
3430: -- clean_evt
3431: -- Procedure to purge the messages in the READY state of a Queue
3432: -- of WF_EVENT_T or AQ$_JMS_TEXT_MESSAGE payload type. Supports time-based selective
3433: -- purge with correlation id.
3434: --
3435: -- IN
3436: -- p_agent_name - Agent Name
3454: l_qname varchar2(80);
3455: l_corrid varchar2(128);
3456: l_queue_name varchar2(80);
3457: l_account_name varchar2(30);
3458: l_payload wf_event_t;
3459: l_msgid raw(16);
3460: l_message_handle raw(16) := NULL;
3461: l_dequeue_options dbms_aq.dequeue_options_t;
3462: l_message_properties dbms_aq.message_properties_t;
3479: SELECT queue_name
3480: INTO l_queue_name
3481: FROM wf_agents
3482: WHERE name = upper(p_agent_name)
3483: AND SYSTEM_GUID = wf_event.local_system_guid;
3484:
3485: l_pos := instr(l_queue_name, '.', 1, 1);
3486: l_schema := substr(l_queue_name, 1, l_pos-1);
3487: l_qname := substr(l_queue_name, l_pos+1);
3519: --
3520: if ((p_correlation is not null) or (p_correlation <> '')) then
3521: -- Seeded WF agents
3522: if (upper(p_agent_name) like 'WF_%') then
3523: if (wf_event.account_name is null) then
3524: wf_event.SetAccountName;
3525: end if;
3526: l_corrid := wf_event.account_name
3527: || ':'
3520: if ((p_correlation is not null) or (p_correlation <> '')) then
3521: -- Seeded WF agents
3522: if (upper(p_agent_name) like 'WF_%') then
3523: if (wf_event.account_name is null) then
3524: wf_event.SetAccountName;
3525: end if;
3526: l_corrid := wf_event.account_name
3527: || ':'
3528: || p_correlation;
3522: if (upper(p_agent_name) like 'WF_%') then
3523: if (wf_event.account_name is null) then
3524: wf_event.SetAccountName;
3525: end if;
3526: l_corrid := wf_event.account_name
3527: || ':'
3528: || p_correlation;
3529: else
3530: l_corrid := p_correlation;
3555: exit when c_msgs%notfound;
3556: l_dequeue_options.msgid := l_msgid;
3557: begin
3558:
3559: if (l_data_type = 'WF_EVENT_T') then
3560: dbms_aq.Dequeue(queue_name => l_queue_name,
3561: dequeue_options => l_dequeue_options,
3562: message_properties => l_message_properties,
3563: payload => l_payload,
3587: raise;
3588: else
3589: l_dequeue_options.navigation := dbms_aq.FIRST_MESSAGE;
3590:
3591: if (l_data_type = 'WF_EVENT_T') then
3592: dbms_aq.Dequeue(queue_name => l_queue_name,
3593: dequeue_options => l_dequeue_options,
3594: message_properties => l_message_properties, /* OUT */
3595: payload => l_payload, /* OUT */