DBA Data[Home] [Help]

APPS.M4U_XML_GENPROCESS_OUT dependencies on DBMS_AQ

Line 2098: l_dequeue_options dbms_aq.dequeue_options_t;

2094: resultout IN OUT NOCOPY VARCHAR2)
2095: IS
2096: l_ecxmsg system.ecxmsg;
2097: l_queue_name varchar2(80);
2098: l_dequeue_options dbms_aq.dequeue_options_t;
2099: l_message_properties dbms_aq.message_properties_t;
2100: l_msgid RAW(16);
2101: l_wait_time NUMBER;
2102: l_group_identifier VARCHAR2(10);

Line 2099: l_message_properties dbms_aq.message_properties_t;

2095: IS
2096: l_ecxmsg system.ecxmsg;
2097: l_queue_name varchar2(80);
2098: l_dequeue_options dbms_aq.dequeue_options_t;
2099: l_message_properties dbms_aq.message_properties_t;
2100: l_msgid RAW(16);
2101: l_wait_time NUMBER;
2102: l_group_identifier VARCHAR2(10);
2103: l_error_code VARCHAR2(50);

Line 2111: l_wait_time := DBMS_AQ.NO_WAIT;

2107: l_event wf_event_t;
2108: BEGIN
2109: l_ecxmsg := null;
2110: l_queue_name := 'ecx_outbound';
2111: l_wait_time := DBMS_AQ.NO_WAIT;
2112:
2113: l_group_identifier := wf_engine.GetItemAttrText(
2114: itemtype,
2115: itemkey,

Line 2166: DBMS_AQ.DEQUEUE(queue_name => l_queue_name,

2162:
2163: l_dequeue_options.wait := l_wait_time;
2164: l_dequeue_options.correlation := l_group_identifier;
2165:
2166: DBMS_AQ.DEQUEUE(queue_name => l_queue_name,
2167: dequeue_options => l_dequeue_options,
2168: message_properties => l_message_properties,
2169: payload => l_ecxmsg,
2170: msgid => l_msgid);