[Home] [Help]
PACKAGE BODY: APPS.OKC_AQ_PUB
Source
1 Package body OKC_AQ_PUB AS
2 /* $Header: OKCPAQB.pls 120.0 2005/05/25 19:35:47 appldev noship $ */
3 l_debug VARCHAR2(1) := NVL(FND_PROFILE.VALUE('AFLOG_ENABLED'),'N');
4 ---------------------------------------------------------------------------
5 -- GLOBAL DATASTRUCTURES
6 ---------------------------------------------------------------------------
7 -- TYPES
8 ---------------------------------------------------------------------------
9 -- CONSTANTS
10 ---------------------------------------------------------------------------
11 -- PUBLIC VARIABLES
12 ---------------------------------------------------------------------------
13 -- EXCEPTIONS
14 ---------------------------------------------------------------------------
15 -----------------------------------
16 -- Private procedures and functions
17 -----------------------------------
18
19 ---------------------------------------------------------------------------
20 -- Procedures and Functions
21 ---------------------------------------------------------------------------
22
23 PROCEDURE send_message
24 (p_api_version IN NUMBER,
25 p_init_msg_list IN VARCHAR2 ,
26 p_commit IN VARCHAR2 ,
27 x_msg_count OUT NOCOPY NUMBER,
28 x_msg_data OUT NOCOPY VARCHAR2,
29 x_return_status OUT NOCOPY VARCHAR2,
30 p_corrid_rec IN okc_aq_pub.corrid_rec_typ,
31 p_msg_tab IN okc_aq_pub.msg_tab_typ,
32 p_queue_name IN VARCHAR2,
33 p_delay IN INTEGER
34 )
35 IS
36 l_api_name CONSTANT VARCHAR2(30) := 'SEND_MESSAGE';
37 l_api_version CONSTANT NUMBER := 1.0;
38 l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
39 l_xml_clob system.okc_aq_msg_typ;
40 --
41 l_proc varchar2(72) := ' OKC_AQ_PUB.'||'send_message';
42 --
43
44 BEGIN
45 IF (l_debug = 'Y') THEN
46 okc_debug.Set_Indentation(l_proc);
47 okc_debug.Log('10: Entering ',2);
48 END IF;
49
50 -- Call start_activity to create savepoint, check compatibility
51 -- and initialize message list
52 l_return_status := OKC_API.START_ACTIVITY ( l_api_name
53 , g_pkg_name
54 , p_init_msg_list
55 , l_api_version
56 , p_api_version
57 , '_PUB'
58 , x_return_status
59 );
60
61 IF (l_debug = 'Y') THEN
62 okc_debug.Log('30: l_return_status : '||l_return_status,2);
63 END IF;
64
65 -- Check if activity started successfully
66 IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
67 RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
68 ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
69 RAISE OKC_API.G_EXCEPTION_ERROR;
70 END IF;
71
72 IF (l_debug = 'Y') THEN
73 okc_debug.Log('40: Calling okc_aq_pvt.send_message ',2);
74 END IF;
75
76 okc_aq_pvt.send_message (
77 p_api_version ,
78 p_init_msg_list ,
79 p_commit ,
80 x_msg_count ,
81 x_msg_data ,
82 x_return_status ,
83 p_corrid_rec ,
84 p_msg_tab ,
85 p_queue_name ,
86 p_delay
87 );
88
89 IF (l_debug = 'Y') THEN
90 okc_debug.Log('50: After Call To okc_aq_pvt.send_message ',2);
91 okc_debug.Log('50: x_msg_count : '||x_msg_count,2);
92 okc_debug.Log('50: x_msg_data : '||x_msg_data,2);
93 okc_debug.Log('50: x_return_status : '||x_return_status,2);
94 END IF;
95
96 -- end activity
97 OKC_API.END_ACTIVITY ( x_msg_count
98 , x_msg_data );
99
100 IF (l_debug = 'Y') THEN
101 okc_debug.Log('1000: Leaving ',2);
102 okc_debug.Reset_Indentation;
103 END IF;
104
105 EXCEPTION
106 WHEN OKC_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
107 x_return_status := OKC_API.HANDLE_EXCEPTIONS (
108 l_api_name
109 , g_pkg_name
110 , 'OKC_API.G_RET_STS_ERROR'
111 , x_msg_count
112 , x_msg_data
113 , '_PUB'
114 );
115 IF (l_debug = 'Y') THEN
116 okc_debug.Log('2000: Leaving ',2);
117 okc_debug.Reset_Indentation;
118 END IF;
119 WHEN OTHERS THEN
120 x_return_status := OKC_API.HANDLE_EXCEPTIONS (
121 l_api_name
122 , g_pkg_name
123 , 'OTHERS'
124 , x_msg_count
125 , x_msg_data
126 , '_PUB'
127 );
128 IF (l_debug = 'Y') THEN
129 okc_debug.Log('3000: Leaving ',2);
130 okc_debug.Reset_Indentation;
131 END IF;
132
133 END send_message;
134
135
136 /*PROCEDURE send_message
137 (p_api_version IN NUMBER,
138 p_init_msg_list IN VARCHAR2 ,
139 p_commit IN VARCHAR2 ,
140 x_msg_count OUT NOCOPY NUMBER,
141 x_msg_data OUT NOCOPY VARCHAR2,
142 x_return_status OUT NOCOPY VARCHAR2,
143 p_msg IN VARCHAR2,
144 p_queue_name IN VARCHAR2,
145 p_delay IN NUMBER ,
146 )
147 IS
148 l_api_name CONSTANT VARCHAR2(30) := 'SEND_MESSAGE';
149 l_api_version CONSTANT NUMBER := 1.0;
150 l_return_status VARCHAR2(1) := OKC_API.G_RET_STS_SUCCESS;
151 l_char_clob system.okc_aq_msg_typ;
152
153 BEGIN
154 IF p_msg IS NOT NULL THEN
155 -- Call start_activity to create savepoint, check compatibility
156 -- and initialize message list
157 l_return_status := OKC_API.START_ACTIVITY ( l_api_name
158 , g_pkg_name
159 , p_init_msg_list
160 , l_api_version
161 , p_api_version
162 , '_PUB'
163 , x_return_status
164 );
165 -- Check if activity started successfully
166 IF (l_return_status = OKC_API.G_RET_STS_UNEXP_ERROR) THEN
167 RAISE OKC_API.G_EXCEPTION_UNEXPECTED_ERROR;
168 ELSIF (l_return_status = OKC_API.G_RET_STS_ERROR) THEN
169 RAISE OKC_API.G_EXCEPTION_ERROR;
170 END IF;
171
172 okc_aq_pvt.send_message (
173 p_api_version ,
174 p_init_msg_list ,
175 p_commit ,
176 x_msg_count ,
177 x_msg_data ,
178 x_return_status ,
179 p_msg ,
180 p_queue_name ,
181 p_delay
182 );
183
184 -- end activity
185 OKC_API.END_ACTIVITY ( x_msg_count
186 , x_msg_data );
187 END IF;
188 EXCEPTION
189 WHEN OKC_API.G_EXCEPTION_UNEXPECTED_ERROR THEN
190 x_return_status := OKC_API.HANDLE_EXCEPTIONS (
191 l_api_name
192 , g_pkg_name
193 , 'OKC_API.G_RET_STS_ERROR'
194 , x_msg_count
195 , x_msg_data
196 , '_PUB'
197 );
198 WHEN OTHERS THEN
199 x_return_status := OKC_API.HANDLE_EXCEPTIONS (
200 l_api_name
201 , g_pkg_name
202 , 'OTHERS'
203 , x_msg_count
204 , x_msg_data
205 , '_PUB'
206 );
207 END send_message;*/
208
209 END okc_aq_pub;