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
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:
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) ;
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 ;
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:
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 */
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,
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 ;
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) ;
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.
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
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:
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
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,
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:
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 ;
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 (
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,
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 ;
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:
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) ;
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:
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:
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,
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,