APPS.FA_ASSET_TRACE_PKG dependencies on DBMS_AQ

Line 1642: enqueue_options DBMS_AQ.enqueue_options_t;

1638: END fparse_header;
1639: --
1640: FUNCTION enqueue_request RETURN BOOLEAN IS
1641:
1642: enqueue_options DBMS_AQ.enqueue_options_t;
1643: message_properties DBMS_AQ.message_properties_t;
1644: message_handle RAW(16);
1645:
1646: BEGIN

Line 1643: message_properties DBMS_AQ.message_properties_t;

1639: --
1640: FUNCTION enqueue_request RETURN BOOLEAN IS
1641:
1642: enqueue_options DBMS_AQ.enqueue_options_t;
1643: message_properties DBMS_AQ.message_properties_t;
1644: message_handle RAW(16);
1645:
1646: BEGIN
1647: DBMS_AQ.ENQUEUE(queue_name => g_qname,

Line 1647: DBMS_AQ.ENQUEUE(queue_name => g_qname,

1643: message_properties DBMS_AQ.message_properties_t;
1644: message_handle RAW(16);
1645:
1646: BEGIN
1647: DBMS_AQ.ENQUEUE(queue_name => g_qname,
1648: enqueue_options => enqueue_options,
1649: message_properties => message_properties,
1650: payload => g_payload,
1651: msgid => message_handle);

Line 1663: dequeue_options DBMS_AQ.dequeue_options_t;

1659: --
1660: FUNCTION dequeue_request (p_request IN VARCHAR2,
1661: x_desc OUT NOCOPY VARCHAR2) RETURN VARCHAR2 IS
1662:
1663: dequeue_options DBMS_AQ.dequeue_options_t;
1664: message_properties DBMS_AQ.message_properties_t;
1665: message_handle RAW(16);
1666: l_agent sys.aq$_agent;
1667: l_req_type VARCHAR2(1) :='P';

Line 1664: message_properties DBMS_AQ.message_properties_t;

1660: FUNCTION dequeue_request (p_request IN VARCHAR2,
1661: x_desc OUT NOCOPY VARCHAR2) RETURN VARCHAR2 IS
1662:
1663: dequeue_options DBMS_AQ.dequeue_options_t;
1664: message_properties DBMS_AQ.message_properties_t;
1665: message_handle RAW(16);
1666: l_agent sys.aq$_agent;
1667: l_req_type VARCHAR2(1) :='P';
1668:

Line 1679: dequeue_options.wait := DBMS_AQ.NO_WAIT;

1675:
1676: l_calling_fn varchar2(80) := 'fa_asset_trace_pkg.dequeue_request';
1677:
1678: BEGIN
1679: dequeue_options.wait := DBMS_AQ.NO_WAIT;
1680: dequeue_options.consumer_name := p_request;
1681: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE;
1682:
1683: begin

Line 1681: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE;

1677:
1678: BEGIN
1679: dequeue_options.wait := DBMS_AQ.NO_WAIT;
1680: dequeue_options.consumer_name := p_request;
1681: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE;
1682:
1683: begin
1684: LOOP
1685: DBMS_AQ.DEQUEUE(queue_name => g_qname,

Line 1685: DBMS_AQ.DEQUEUE(queue_name => g_qname,

1681: dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE;
1682:
1683: begin
1684: LOOP
1685: DBMS_AQ.DEQUEUE(queue_name => g_qname,
1686: dequeue_options => dequeue_options,
1687: message_properties => message_properties,
1688: payload => g_payload,
1689: msgid => message_handle);

Line 1692: dequeue_options.navigation := DBMS_AQ.NEXT_MESSAGE;

1688: payload => g_payload,
1689: msgid => message_handle);
1690: l_req_type := g_payload.req_type;
1691: x_desc := g_payload.l_desc;
1692: dequeue_options.navigation := DBMS_AQ.NEXT_MESSAGE;
1693: END LOOP;
1694: --remove subscriber.
1695: l_agent := sys.aq$_agent(p_request,null,null);
1696: dbms_aqadm.remove_subscriber(queue_name => g_qname, subscriber => l_agent);

Line 1696: dbms_aqadm.remove_subscriber(queue_name => g_qname, subscriber => l_agent);

1692: dequeue_options.navigation := DBMS_AQ.NEXT_MESSAGE;
1693: END LOOP;
1694: --remove subscriber.
1695: l_agent := sys.aq$_agent(p_request,null,null);
1696: dbms_aqadm.remove_subscriber(queue_name => g_qname, subscriber => l_agent);
1697: COMMIT;
1698: exception
1699: WHEN no_messages THEN
1700: log(l_calling_fn,'Queue is empty.');