DBA Data[Home] [Help]

APPS.XNP_ACK_U dependencies on XNP_MESSAGE

Line 5: x_msg_header OUT NOCOPY XNP_MESSAGE.MSG_HEADER_REC_TYPE,

1: PACKAGE BODY XNP_ACK_U AS
2: /* $Header: XNPACKSB.pls 120.2 2006/02/13 05:58:07 dputhiye ship $*/
3: PROCEDURE CREATE_MSG ( XNP$CODE NUMBER,
4: XNP$DESCRIPTION VARCHAR2,
5: x_msg_header OUT NOCOPY XNP_MESSAGE.MSG_HEADER_REC_TYPE,
6: x_msg_text OUT NOCOPY VARCHAR2,
7: x_error_code OUT NOCOPY NUMBER,
8: x_error_message OUT NOCOPY VARCHAR2,
9: p_sender_name IN VARCHAR2 DEFAULT NULL,

Line 24: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;

20: e_NO_DESTINATION EXCEPTION ;
21: l_xml_body VARCHAR2(32767) ;
22: l_xml_doc VARCHAR2(32767) ;
23: l_xml_header VARCHAR2(32767) ;
24: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;
25: BEGIN
26: x_error_code := 0 ;
27: x_error_message := NULL ;
28: XNP_XML_UTILS.initialize_doc ( ) ;

Line 40: XNP_MESSAGE.get_sequence ( l_msg_header.message_id ) ;

36: /* initialize the XML header variable */
37: XNP_XML_UTILS.initialize_doc ( ) ;
38: /*construct the XML header */
39: /* retreive the next message ID */
40: XNP_MESSAGE.get_sequence ( l_msg_header.message_id ) ;
41: IF (p_reference_id IS NULL) THEN
42: l_msg_header.reference_id := l_msg_header.message_id ;
43: ELSE
44: l_msg_header.reference_id := p_reference_id ;

Line 106: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;

102: e_NO_DESTINATION EXCEPTION ;
103: l_recipient_list VARCHAR2 (2000) ;
104: l_consumer_list VARCHAR2 (4000) ;
105: l_queue_name VARCHAR2 (2000) ;
106: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;
107: l_msg_text VARCHAR2(32767) ;
108: BEGIN
109: x_error_code := 0 ;
110: x_error_message := NULL ;

Line 114: XNP_MESSAGE.GET_SUBSCRIBER_LIST( 'ACK', l_consumer_list );

110: x_error_message := NULL ;
111: /* check if the consumer list is NULL */
112: l_consumer_list := p_consumer_list ;
113: IF (l_consumer_list IS NULL) THEN
114: XNP_MESSAGE.GET_SUBSCRIBER_LIST( 'ACK', l_consumer_list );
115: END IF;
116: l_recipient_list := p_recipient_list ;
117: l_queue_name := 'XNP_IN_MSG_Q';
118: /* create the XML message */

Line 137: XNP_MESSAGE.push (

133: p_fa_instance_id=>p_fa_instance_id ) ;
134: x_message_id := l_msg_header.message_id ;
135: /* enqueue the XML message for delivery */
136: IF (x_error_code = 0) THEN
137: XNP_MESSAGE.push (
138: p_msg_header => l_msg_header,
139: p_body_text => l_msg_text,
140: p_queue_name => xnp_event.c_inbound_msg_q,
141: p_correlation_id => 'MSG_SERVER',

Line 143: p_commit_mode => XNP_MESSAGE.C_ON_COMMIT );

139: p_body_text => l_msg_text,
140: p_queue_name => xnp_event.c_inbound_msg_q,
141: p_correlation_id => 'MSG_SERVER',
142: p_priority=>'3',
143: p_commit_mode => XNP_MESSAGE.C_ON_COMMIT );
144: /* out processing logic */
145: NULL;
146: END IF ;
147: EXCEPTION

Line 192: PROCEDURE PROCESS ( p_msg_header IN XNP_MESSAGE.MSG_HEADER_REC_TYPE,

188: p_order_id=>p_order_id,
189: p_wi_instance_id=>p_wi_instance_id,
190: p_fa_instance_id=>p_fa_instance_id ) ;
191: END ;
192: PROCEDURE PROCESS ( p_msg_header IN XNP_MESSAGE.MSG_HEADER_REC_TYPE,
193: p_msg_text IN VARCHAR2,
194: x_error_code OUT NOCOPY NUMBER,
195: x_error_message OUT NOCOPY VARCHAR2,
196: p_process_reference IN VARCHAR2 DEFAULT NULL ) IS

Line 201: PROCEDURE VALIDATE ( p_msg_header IN OUT NOCOPY XNP_MESSAGE.MSG_HEADER_REC_TYPE,

197: BEGIN
198: NULL ;
199: NULL ;
200: END ;
201: PROCEDURE VALIDATE ( p_msg_header IN OUT NOCOPY XNP_MESSAGE.MSG_HEADER_REC_TYPE,
202: p_msg_text IN VARCHAR2,
203: x_error_code OUT NOCOPY NUMBER,
204: x_error_message OUT NOCOPY VARCHAR2 ) IS
205: BEGIN

Line 209: PROCEDURE DEFAULT_PROCESS ( p_msg_header IN XNP_MESSAGE.MSG_HEADER_REC_TYPE,

205: BEGIN
206: NULL ;
207: NULL;
208: END ;
209: PROCEDURE DEFAULT_PROCESS ( p_msg_header IN XNP_MESSAGE.MSG_HEADER_REC_TYPE,
210: p_msg_text IN VARCHAR2,
211: x_error_code OUT NOCOPY NUMBER,
212: x_error_message OUT NOCOPY VARCHAR2 ) IS
213: BEGIN