[Home] [Help]
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;
3138: pragma EXCEPTION_INIT(invalid_agent, -20201);
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
3219: begin
3220: --Dequeue the message from the exception queue
3238: l_timeout := 1;
3239: when others then
3240: raise;
3241: end;
3242: end loop; --End of while loop that handles AQ$_JMS_TEXT_MESSAGE payload
3243:
3244: else
3245: -- Payload not supported by this API, raise application error
3246: raise_application_error(-20202, 'Invalid payload type');
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)
3296: l_message_properties dbms_aq.message_properties_t;
3297:
3298: -- Bug 6112028
3299: l_data_type VARCHAR2(106);
3300: l_payload_jms SYS.AQ$_JMS_TEXT_MESSAGE;
3301:
3302: --Define the snapshot too old error
3303: snap_too_old exception;
3304: pragma exception_init(snap_too_old, -1555);
3368: dequeue_options => l_dequeue_options,
3369: message_properties => l_message_properties, /* OUT */
3370: payload => l_payload, /* OUT */
3371: msgid => l_message_handle); /* OUT */
3372: elsif l_data_type = 'AQ$_JMS_TEXT_MESSAGE' then
3373: dbms_aq.Dequeue(queue_name => l_queue_name,
3374: dequeue_options => l_dequeue_options,
3375: message_properties => l_message_properties, /* OUT */
3376: payload => l_payload_jms, /* OUT */
3405: message_properties => l_message_properties, /* OUT */
3406: payload => l_payload, /* OUT */
3407: msgid => l_message_handle); /* OUT */
3408:
3409: elsif l_data_type = 'AQ$_JMS_TEXT_MESSAGE' then
3410: dbms_aq.Dequeue(queue_name => l_queue_name,
3411: dequeue_options => l_dequeue_options,
3412: message_properties => l_message_properties, /* OUT */
3413: payload => l_payload_jms, /* OUT */
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
3482: l_message_properties dbms_aq.message_properties_t;
3483:
3484: -- Bug 6112028
3485: l_data_type VARCHAR2(106);
3486: l_payload_jms SYS.AQ$_JMS_TEXT_MESSAGE;
3487:
3488: -- Cursor to get all messages from the queue that were enqueued before
3489: -- a given date.
3490: TYPE c_msgs_typ IS REF CURSOR;
3581: dequeue_options => l_dequeue_options,
3582: message_properties => l_message_properties,
3583: payload => l_payload,
3584: msgid => l_message_handle);
3585: elsif l_data_type = 'AQ$_JMS_TEXT_MESSAGE' then
3586:
3587: dbms_aq.Dequeue(queue_name => l_queue_name,
3588: dequeue_options => l_dequeue_options,
3589: message_properties => l_message_properties,
3614: message_properties => l_message_properties, /* OUT */
3615: payload => l_payload, /* OUT */
3616: msgid => l_message_handle); /* OUT */
3617:
3618: elsif l_data_type = 'AQ$_JMS_TEXT_MESSAGE' then
3619: dbms_aq.Dequeue(queue_name => l_queue_name,
3620: dequeue_options => l_dequeue_options,
3621: message_properties => l_message_properties, /* OUT */
3622: payload => l_payload_jms, /* OUT */