DBA Data[Home] [Help]

APPS.XNP_MESSAGE dependencies on DBMS_AQ

Line 446: ,p_delay IN NUMBER DEFAULT DBMS_AQ.NO_DELAY

442: ,p_recipient_list IN VARCHAR2 DEFAULT NULL
443: ,p_correlation_id IN VARCHAR2 DEFAULT NULL
444: ,p_priority IN INTEGER DEFAULT 1
445: ,p_commit_mode IN NUMBER DEFAULT c_on_commit
446: ,p_delay IN NUMBER DEFAULT DBMS_AQ.NO_DELAY
447: ,p_fe_name IN VARCHAR2 DEFAULT NULL
448: ,p_adapter_name IN VARCHAR2 DEFAULT NULL
449: )
450: IS

Line 453: my_enqueue_options dbms_aq.enqueue_options_t ;

449: )
450: IS
451:
452: l_message SYSTEM.XNP_MESSAGE_TYPE ;
453: my_enqueue_options dbms_aq.enqueue_options_t ;
454: message_properties dbms_aq.message_properties_t ;
455: message_handle RAW(16) ;
456: recipients dbms_aq.aq$_recipient_list_t ;
457:

Line 454: message_properties dbms_aq.message_properties_t ;

450: IS
451:
452: l_message SYSTEM.XNP_MESSAGE_TYPE ;
453: my_enqueue_options dbms_aq.enqueue_options_t ;
454: message_properties dbms_aq.message_properties_t ;
455: message_handle RAW(16) ;
456: recipients dbms_aq.aq$_recipient_list_t ;
457:
458: l_recipient_name VARCHAR2(80) ;

Line 456: recipients dbms_aq.aq$_recipient_list_t ;

452: l_message SYSTEM.XNP_MESSAGE_TYPE ;
453: my_enqueue_options dbms_aq.enqueue_options_t ;
454: message_properties dbms_aq.message_properties_t ;
455: message_handle RAW(16) ;
456: recipients dbms_aq.aq$_recipient_list_t ;
457:
458: l_recipient_name VARCHAR2(80) ;
459: l_recipient_count INTEGER ;
460: l_initial_pos INTEGER ;

Line 692: my_enqueue_options.visibility := DBMS_AQ.IMMEDIATE ;

688:
689: END IF ;
690:
691: IF (p_commit_mode = C_IMMEDIATE) THEN
692: my_enqueue_options.visibility := DBMS_AQ.IMMEDIATE ;
693: ELSE
694: my_enqueue_options.visibility := DBMS_AQ.ON_COMMIT ;
695: END IF ;
696:

Line 694: my_enqueue_options.visibility := DBMS_AQ.ON_COMMIT ;

690:
691: IF (p_commit_mode = C_IMMEDIATE) THEN
692: my_enqueue_options.visibility := DBMS_AQ.IMMEDIATE ;
693: ELSE
694: my_enqueue_options.visibility := DBMS_AQ.ON_COMMIT ;
695: END IF ;
696:
697:
698: /* smoolcha removed hard coded strings for bug 3537148 */

Line 720: DBMS_AQ.ENQUEUE (

716: ELSIF instr(p_queue_name,'XNP_OUT_MSG_Q') > 0 THEN
717: message_properties.exception_queue := g_xnp_schema || '.XNP_OUT_MSG_EXCEPTION_Q' ;
718: END IF ;
719:
720: DBMS_AQ.ENQUEUE (
721: queue_name => p_queue_name ,
722: enqueue_options => my_enqueue_options,
723: message_properties => message_properties,
724: payload => l_message,

Line 810: my_dequeue_options dbms_aq.dequeue_options_t ;

806: IS
807:
808: l_msg_status VARCHAR2(40) ;
809: l_message SYSTEM.XNP_MESSAGE_TYPE ;
810: my_dequeue_options dbms_aq.dequeue_options_t ;
811: message_properties dbms_aq.message_properties_t ;
812: message_handle RAW(16) ;
813: l_timeout NUMBER ;
814: e_q_time_out EXCEPTION ;

Line 811: message_properties dbms_aq.message_properties_t ;

807:
808: l_msg_status VARCHAR2(40) ;
809: l_message SYSTEM.XNP_MESSAGE_TYPE ;
810: my_dequeue_options dbms_aq.dequeue_options_t ;
811: message_properties dbms_aq.message_properties_t ;
812: message_handle RAW(16) ;
813: l_timeout NUMBER ;
814: e_q_time_out EXCEPTION ;
815: l_fnd_message VARCHAR2(4000) ;

Line 831: my_dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;

827: IF ( POP_TIMEOUT <> 0 ) THEN
828: my_dequeue_options.wait := POP_TIMEOUT ;
829: END IF ;
830:
831: my_dequeue_options.navigation := DBMS_AQ.FIRST_MESSAGE ;
832:
833: --
834: --setting the consumer name would only dequeue messages
835: --destined for that consumer.

Line 854: my_dequeue_options.DEQUEUE_MODE := DBMS_AQ.REMOVE ;

850: IF ( p_msg_id IS NOT NULL ) THEN
851: my_dequeue_options.msgid := p_msg_id ;
852: END IF ;
853:
854: my_dequeue_options.DEQUEUE_MODE := DBMS_AQ.REMOVE ;
855:
856: IF (p_commit_mode = C_IMMEDIATE) THEN
857: my_dequeue_options.visibility := DBMS_AQ.IMMEDIATE ;
858: ELSE

Line 857: my_dequeue_options.visibility := DBMS_AQ.IMMEDIATE ;

853:
854: my_dequeue_options.DEQUEUE_MODE := DBMS_AQ.REMOVE ;
855:
856: IF (p_commit_mode = C_IMMEDIATE) THEN
857: my_dequeue_options.visibility := DBMS_AQ.IMMEDIATE ;
858: ELSE
859: my_dequeue_options.visibility := DBMS_AQ.ON_COMMIT ;
860: END IF ;
861:

Line 859: my_dequeue_options.visibility := DBMS_AQ.ON_COMMIT ;

855:
856: IF (p_commit_mode = C_IMMEDIATE) THEN
857: my_dequeue_options.visibility := DBMS_AQ.IMMEDIATE ;
858: ELSE
859: my_dequeue_options.visibility := DBMS_AQ.ON_COMMIT ;
860: END IF ;
861:
862: /* Loop till the FIRST 'READY' message is obtained */
863: -- bellsouth 1482985

Line 871: DBMS_AQ.DEQUEUE (

867: -- 'PROCESSED' message also.
868:
869: LOOP
870:
871: DBMS_AQ.DEQUEUE (
872: queue_name => p_queue_name ,
873: dequeue_options => my_dequeue_options,
874: message_properties => message_properties,
875: payload => l_message,

Line 1444: my_enqueue_options dbms_aq.enqueue_options_t ;

1440: l_msg_text VARCHAR2(32767) ;
1441:
1442: l_message SYSTEM.XNP_MESSAGE_TYPE ;
1443: l_msg_id XNP_MSGS.MSG_ID%TYPE ;
1444: my_enqueue_options dbms_aq.enqueue_options_t ;
1445: message_properties dbms_aq.message_properties_t ;
1446: message_handle RAW(16) ;
1447:
1448:

Line 1445: message_properties dbms_aq.message_properties_t ;

1441:
1442: l_message SYSTEM.XNP_MESSAGE_TYPE ;
1443: l_msg_id XNP_MSGS.MSG_ID%TYPE ;
1444: my_enqueue_options dbms_aq.enqueue_options_t ;
1445: message_properties dbms_aq.message_properties_t ;
1446: message_handle RAW(16) ;
1447:
1448:
1449: l_feedback VARCHAR2(4000) := NULL ;

Line 1464: my_enqueue_options.visibility := DBMS_AQ.ON_COMMIT ;

1460: message_properties.priority := 3 ;
1461: -- changed for specialization support adabholk 07/2001
1462: -- message_properties.correlation := 'MSG_SERVER' ;
1463: message_properties.correlation := l_msg_header.message_code;
1464: my_enqueue_options.visibility := DBMS_AQ.ON_COMMIT ;
1465:
1466: l_message := SYSTEM.xnp_message_type(p_msg_id) ;
1467:
1468: DBMS_AQ.ENQUEUE (

Line 1468: DBMS_AQ.ENQUEUE (

1464: my_enqueue_options.visibility := DBMS_AQ.ON_COMMIT ;
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,

Line 2018: p_delay IN NUMBER DEFAULT DBMS_AQ.NO_DELAY ) IS

2014: p_queue_name IN VARCHAR2 ,
2015: p_correlation_id IN VARCHAR2 DEFAULT NULL ,
2016: p_priority IN INTEGER DEFAULT 1 ,
2017: p_commit_mode IN NUMBER DEFAULT c_on_commit ,
2018: p_delay IN NUMBER DEFAULT DBMS_AQ.NO_DELAY ) IS
2019:
2020: l_event WF_EVENT_T ;
2021: l_event_key VARCHAR2(30) := '1';
2022: my_enqueue_options dbms_aq.enqueue_options_t ;

Line 2022: my_enqueue_options dbms_aq.enqueue_options_t ;

2018: p_delay IN NUMBER DEFAULT DBMS_AQ.NO_DELAY ) IS
2019:
2020: l_event WF_EVENT_T ;
2021: l_event_key VARCHAR2(30) := '1';
2022: my_enqueue_options dbms_aq.enqueue_options_t ;
2023: message_properties dbms_aq.message_properties_t ;
2024: message_handle RAW(16) ;
2025: recipients dbms_aq.aq$_recipient_list_t ;
2026:

Line 2023: message_properties dbms_aq.message_properties_t ;

2019:
2020: l_event WF_EVENT_T ;
2021: l_event_key VARCHAR2(30) := '1';
2022: my_enqueue_options dbms_aq.enqueue_options_t ;
2023: message_properties dbms_aq.message_properties_t ;
2024: message_handle RAW(16) ;
2025: recipients dbms_aq.aq$_recipient_list_t ;
2026:
2027: l_recipient_name VARCHAR2(80) ;

Line 2025: recipients dbms_aq.aq$_recipient_list_t ;

2021: l_event_key VARCHAR2(30) := '1';
2022: my_enqueue_options dbms_aq.enqueue_options_t ;
2023: message_properties dbms_aq.message_properties_t ;
2024: message_handle RAW(16) ;
2025: recipients dbms_aq.aq$_recipient_list_t ;
2026:
2027: l_recipient_name VARCHAR2(80) ;
2028: l_recipient_count INTEGER ;
2029:

Line 2054: my_enqueue_options.visibility := DBMS_AQ.IMMEDIATE ;

2050: message_properties.correlation := l_correlation_id ;
2051: END IF ;
2052:
2053: IF (p_commit_mode = C_IMMEDIATE) THEN
2054: my_enqueue_options.visibility := DBMS_AQ.IMMEDIATE ;
2055: ELSE
2056: my_enqueue_options.visibility := DBMS_AQ.ON_COMMIT ;
2057: END IF ;
2058:

Line 2056: my_enqueue_options.visibility := DBMS_AQ.ON_COMMIT ;

2052:
2053: IF (p_commit_mode = C_IMMEDIATE) THEN
2054: my_enqueue_options.visibility := DBMS_AQ.IMMEDIATE ;
2055: ELSE
2056: my_enqueue_options.visibility := DBMS_AQ.ON_COMMIT ;
2057: END IF ;
2058:
2059: XDP_UTILITIES.WRITE_TABLE_TO_CLOB(p_source_table => xdp_utilities.g_message_list,
2060: p_dest_clob => xdp_utilities.g_clob,

Line 2074: DBMS_AQ.ENQUEUE (

2070: l_event.EVENT_NAME := l_msg_header.message_code;
2071: l_event.EVENT_KEY := l_event_key ;
2072: l_event.EVENT_DATA := xdp_utilities.g_clob ;
2073:
2074: DBMS_AQ.ENQUEUE (
2075: queue_name => p_queue_name ,
2076: enqueue_options => my_enqueue_options,
2077: message_properties => message_properties,
2078: payload => l_event,