APPS.XNP_MESSAGE dependencies on XNP_EVENT

Line 881: IF(p_queue_name = xnp_event.c_inbound_msg_q) THEN

877:
878: BEGIN
879: XDP_AQ_UTILITIES.SET_CONTEXT( l_message.message_id, 'MESSAGE_OBJECT');
880:
881: IF(p_queue_name = xnp_event.c_inbound_msg_q) THEN
882:
883: IF(g_APPS_MAINTENANCE_MODE = 'MAINT') THEN
884:
885: SELECT count(*)

Line 961: xnp_event_subscribers ESS

957: CURSOR get_subscribers (message_code IN VARCHAR2) IS
958: SELECT xnp_utils.get_adapter_using_fe(
959: FET.fulfillment_element_name) adapter_name
960: FROM xdp_fes FET,
961: xnp_event_subscribers ESS
962: WHERE FET.FE_ID = ESS.FE_ID
963: AND ESS.msg_code = message_code ;
964:
965: l_subscriber_count INTEGER ;

Line 1469: queue_name => XNP_EVENT.C_INBOUND_MSG_Q ,

1465:
1466: l_message := SYSTEM.xnp_message_type(p_msg_id) ;
1467:
1468: DBMS_AQ.ENQUEUE (
1469: queue_name => XNP_EVENT.C_INBOUND_MSG_Q ,
1470: enqueue_options => my_enqueue_options,
1471: message_properties => message_properties,
1472: payload => l_message,
1473: msgid => message_handle ) ;

Line 1807: DELETE FROM xnp_event_subscribers

1803: DELETE FROM xnp_timer_publishers
1804: WHERE timer_message_code = p_msg_code
1805: OR source_message_code = p_msg_code;
1806:
1807: DELETE FROM xnp_event_subscribers
1808: WHERE msg_code = p_msg_code;
1809:
1810: BEGIN
1811: xnp_msg_types_pkg.delete_row(p_msg_code) ;