[Home] [Help]
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;
3118: pragma EXCEPTION_INIT(invalid_agent, -20201);
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
3199: begin
3200: --Dequeue the message from the exception queue
3218: l_timeout := 1;
3219: when others then
3220: raise;
3221: end;
3222: end loop; --End of while loop that handles AQ$_JMS_TEXT_MESSAGE payload
3223:
3224: else
3225: -- Payload not supported by this API, raise application error
3226: raise_application_error(-20202, 'Invalid payload type');
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)
3276: l_message_properties dbms_aq.message_properties_t;
3277:
3278: -- Bug 6112028
3279: l_data_type VARCHAR2(106);
3280: l_payload_jms SYS.AQ$_JMS_TEXT_MESSAGE;
3281:
3282: --Define the snapshot too old error
3283: snap_too_old exception;
3284: pragma exception_init(snap_too_old, -1555);
3348: dequeue_options => l_dequeue_options,
3349: message_properties => l_message_properties, /* OUT */
3350: payload => l_payload, /* OUT */
3351: msgid => l_message_handle); /* OUT */
3352: elsif l_data_type = 'AQ$_JMS_TEXT_MESSAGE' then
3353: dbms_aq.Dequeue(queue_name => l_queue_name,
3354: dequeue_options => l_dequeue_options,
3355: message_properties => l_message_properties, /* OUT */
3356: payload => l_payload_jms, /* OUT */
3385: message_properties => l_message_properties, /* OUT */
3386: payload => l_payload, /* OUT */
3387: msgid => l_message_handle); /* OUT */
3388:
3389: elsif l_data_type = 'AQ$_JMS_TEXT_MESSAGE' then
3390: dbms_aq.Dequeue(queue_name => l_queue_name,
3391: dequeue_options => l_dequeue_options,
3392: message_properties => l_message_properties, /* OUT */
3393: payload => l_payload_jms, /* 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
3462: l_message_properties dbms_aq.message_properties_t;
3463:
3464: -- Bug 6112028
3465: l_data_type VARCHAR2(106);
3466: l_payload_jms SYS.AQ$_JMS_TEXT_MESSAGE;
3467:
3468: -- Cursor to get all messages from the queue that were enqueued before
3469: -- a given date.
3470: TYPE c_msgs_typ IS REF CURSOR;
3561: dequeue_options => l_dequeue_options,
3562: message_properties => l_message_properties,
3563: payload => l_payload,
3564: msgid => l_message_handle);
3565: elsif l_data_type = 'AQ$_JMS_TEXT_MESSAGE' then
3566:
3567: dbms_aq.Dequeue(queue_name => l_queue_name,
3568: dequeue_options => l_dequeue_options,
3569: message_properties => l_message_properties,
3594: message_properties => l_message_properties, /* OUT */
3595: payload => l_payload, /* OUT */
3596: msgid => l_message_handle); /* OUT */
3597:
3598: elsif l_data_type = 'AQ$_JMS_TEXT_MESSAGE' then
3599: dbms_aq.Dequeue(queue_name => l_queue_name,
3600: dequeue_options => l_dequeue_options,
3601: message_properties => l_message_properties, /* OUT */
3602: payload => l_payload_jms, /* OUT */