DBA Data[Home] [Help]

APPS.FND_CP_TMSRV_QUEUE dependencies on FNDCP_TMSRV

Line 31: P_DEBUG varchar2(1) := FNDCP_TMSRV.DBG_OFF;

27: --
28: -- Private variables
29: --
30:
31: P_DEBUG varchar2(1) := FNDCP_TMSRV.DBG_OFF;
32: Q_Name varchar2(64) := null;
33: RetQ_Name varchar2(64) := null;
34: P_SENDER_ID varchar2(30) := null;
35: P_SENDER_AGENT sys.aq$_agent;

Line 80: e_code := FNDCP_TMSRV.E_SUCCESS;

76:
77: Q_Name := schema || '.' || QUEUE_NAME;
78: RetQ_Name := schema || '.' || RETURN_QUEUE_NAME;
79:
80: e_code := FNDCP_TMSRV.E_SUCCESS;
81:
82: commit;
83:
84: end initialize;

Line 91: FNDCP_TMSRV.P_DEBUG := dbgtype;

87:
88: procedure set_debug(dbgtype in varchar2) is
89: begin
90: P_DEBUG := dbgtype;
91: FNDCP_TMSRV.P_DEBUG := dbgtype;
92: end set_debug;
93:
94:
95:

Line 164: e_code := FNDCP_TMSRV.E_SUCCESS;

160: MESSAGE_PROPERTIES => msg_props,
161: PAYLOAD => payload,
162: MSGID => msgid);
163:
164: e_code := FNDCP_TMSRV.E_SUCCESS;
165:
166: exception
167: when queue_timeout then
168: e_code := FNDCP_TMSRV.E_TIMEOUT;

Line 168: e_code := FNDCP_TMSRV.E_TIMEOUT;

164: e_code := FNDCP_TMSRV.E_SUCCESS;
165:
166: exception
167: when queue_timeout then
168: e_code := FNDCP_TMSRV.E_TIMEOUT;
169: return;
170:
171: when others then
172: fndcp_tmsrv.debug_info('tmsrv_queue.read_message', 'Caught exception in DQ', sqlerrm);

Line 172: fndcp_tmsrv.debug_info('tmsrv_queue.read_message', 'Caught exception in DQ', sqlerrm);

168: e_code := FNDCP_TMSRV.E_TIMEOUT;
169: return;
170:
171: when others then
172: fndcp_tmsrv.debug_info('tmsrv_queue.read_message', 'Caught exception in DQ', sqlerrm);
173: return;
174: end;
175:
176:

Line 178: if (pktyp not in (FNDCP_TMSRV.PK_TRN, FNDCP_TMSRV.PK_TRN_D1, FNDCP_TMSRV.PK_TRN_D2)) then

174: end;
175:
176:
177: pktyp := payload.msgtype;
178: if (pktyp not in (FNDCP_TMSRV.PK_TRN, FNDCP_TMSRV.PK_TRN_D1, FNDCP_TMSRV.PK_TRN_D2)) then
179: e_code := FNDCP_TMSRV.E_OTHER;
180: return;
181: end if;
182:

Line 179: e_code := FNDCP_TMSRV.E_OTHER;

175:
176:
177: pktyp := payload.msgtype;
178: if (pktyp not in (FNDCP_TMSRV.PK_TRN, FNDCP_TMSRV.PK_TRN_D1, FNDCP_TMSRV.PK_TRN_D2)) then
179: e_code := FNDCP_TMSRV.E_OTHER;
180: return;
181: end if;
182:
183: set_debug(pktyp);

Line 243: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then

239: if arg_19 <> chr(0) then numargs := numargs + 1; end if;
240: arg_20 := payload.arg20;
241: if arg_20 <> chr(0) then numargs := numargs + 1; end if;
242:
243: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then
244: fndcp_tmsrv.debug_info('TMSRV_QUEUE.read_message',
245: 'Unpacked request details', NULL, 'M');
246:
247: end if;

Line 244: fndcp_tmsrv.debug_info('TMSRV_QUEUE.read_message',

240: arg_20 := payload.arg20;
241: if arg_20 <> chr(0) then numargs := numargs + 1; end if;
242:
243: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then
244: fndcp_tmsrv.debug_info('TMSRV_QUEUE.read_message',
245: 'Unpacked request details', NULL, 'M');
246:
247: end if;
248:

Line 252: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then

248:
249: sql_stmt := 'ALTER SESSION SET SQL_TRACE = '|| enable_trace;
250: EXECUTE IMMEDIATE sql_stmt ;
251:
252: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then
253: fndcp_tmsrv.debug_info('TMSRV_QUEUE.read_message',
254: 'SQL_TRACE:', enable_trace, 'M');
255:
256: end if;

Line 253: fndcp_tmsrv.debug_info('TMSRV_QUEUE.read_message',

249: sql_stmt := 'ALTER SESSION SET SQL_TRACE = '|| enable_trace;
250: EXECUTE IMMEDIATE sql_stmt ;
251:
252: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then
253: fndcp_tmsrv.debug_info('TMSRV_QUEUE.read_message',
254: 'SQL_TRACE:', enable_trace, 'M');
255:
256: end if;
257:

Line 266: fndcp_tmsrv.debug_info('tmsrv_queue.read_message', 'Caught exception', sqlerrm);

262: fnd_message.set_name ('FND', 'SQL-Generic error');
263: fnd_message.set_token ('ERRNO', sqlcode, FALSE);
264: fnd_message.set_token ('REASON', sqlerrm, FALSE);
265: fnd_message.set_token ('ROUTINE', 'TMSRV_QUEUE.READ_MESSAGE', FALSE);
266: fndcp_tmsrv.debug_info('tmsrv_queue.read_message', 'Caught exception', sqlerrm);
267: e_code := FNDCP_TMSRV.E_OTHER;
268: end read_message;
269:
270:

Line 267: e_code := FNDCP_TMSRV.E_OTHER;

263: fnd_message.set_token ('ERRNO', sqlcode, FALSE);
264: fnd_message.set_token ('REASON', sqlerrm, FALSE);
265: fnd_message.set_token ('ROUTINE', 'TMSRV_QUEUE.READ_MESSAGE', FALSE);
266: fndcp_tmsrv.debug_info('tmsrv_queue.read_message', 'Caught exception', sqlerrm);
267: e_code := FNDCP_TMSRV.E_OTHER;
268: end read_message;
269:
270:
271:

Line 286: e_code := FNDCP_TMSRV.E_SUCCESS;

282: msg system.FND_CP_TM_AQ_PAYLOAD;
283:
284: begin
285:
286: e_code := FNDCP_TMSRV.E_SUCCESS;
287:
288: FNDCP_TMSRV.P_RETVALCOUNT := 0; -- Reset the return values table.
289:
290: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then

Line 288: FNDCP_TMSRV.P_RETVALCOUNT := 0; -- Reset the return values table.

284: begin
285:
286: e_code := FNDCP_TMSRV.E_SUCCESS;
287:
288: FNDCP_TMSRV.P_RETVALCOUNT := 0; -- Reset the return values table.
289:
290: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then
291: fndcp_tmsrv.debug_info('TMSRV_QUEUE.write_message',
292: 'Packing return message' ,

Line 290: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then

286: e_code := FNDCP_TMSRV.E_SUCCESS;
287:
288: FNDCP_TMSRV.P_RETVALCOUNT := 0; -- Reset the return values table.
289:
290: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then
291: fndcp_tmsrv.debug_info('TMSRV_QUEUE.write_message',
292: 'Packing return message' ,
293: reqid, 'S');
294:

Line 291: fndcp_tmsrv.debug_info('TMSRV_QUEUE.write_message',

287:
288: FNDCP_TMSRV.P_RETVALCOUNT := 0; -- Reset the return values table.
289:
290: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then
291: fndcp_tmsrv.debug_info('TMSRV_QUEUE.write_message',
292: 'Packing return message' ,
293: reqid, 'S');
294:
295: end if;

Line 315: FNDCP_TMSRV.P_RETURN_VALS(1),

311: outcome,
312: message,
313: null,
314: null,
315: FNDCP_TMSRV.P_RETURN_VALS(1),
316: FNDCP_TMSRV.P_RETURN_VALS(2),
317: FNDCP_TMSRV.P_RETURN_VALS(3),
318: FNDCP_TMSRV.P_RETURN_VALS(4),
319: FNDCP_TMSRV.P_RETURN_VALS(5),

Line 316: FNDCP_TMSRV.P_RETURN_VALS(2),

312: message,
313: null,
314: null,
315: FNDCP_TMSRV.P_RETURN_VALS(1),
316: FNDCP_TMSRV.P_RETURN_VALS(2),
317: FNDCP_TMSRV.P_RETURN_VALS(3),
318: FNDCP_TMSRV.P_RETURN_VALS(4),
319: FNDCP_TMSRV.P_RETURN_VALS(5),
320: FNDCP_TMSRV.P_RETURN_VALS(6),

Line 317: FNDCP_TMSRV.P_RETURN_VALS(3),

313: null,
314: null,
315: FNDCP_TMSRV.P_RETURN_VALS(1),
316: FNDCP_TMSRV.P_RETURN_VALS(2),
317: FNDCP_TMSRV.P_RETURN_VALS(3),
318: FNDCP_TMSRV.P_RETURN_VALS(4),
319: FNDCP_TMSRV.P_RETURN_VALS(5),
320: FNDCP_TMSRV.P_RETURN_VALS(6),
321: FNDCP_TMSRV.P_RETURN_VALS(7),

Line 318: FNDCP_TMSRV.P_RETURN_VALS(4),

314: null,
315: FNDCP_TMSRV.P_RETURN_VALS(1),
316: FNDCP_TMSRV.P_RETURN_VALS(2),
317: FNDCP_TMSRV.P_RETURN_VALS(3),
318: FNDCP_TMSRV.P_RETURN_VALS(4),
319: FNDCP_TMSRV.P_RETURN_VALS(5),
320: FNDCP_TMSRV.P_RETURN_VALS(6),
321: FNDCP_TMSRV.P_RETURN_VALS(7),
322: FNDCP_TMSRV.P_RETURN_VALS(8),

Line 319: FNDCP_TMSRV.P_RETURN_VALS(5),

315: FNDCP_TMSRV.P_RETURN_VALS(1),
316: FNDCP_TMSRV.P_RETURN_VALS(2),
317: FNDCP_TMSRV.P_RETURN_VALS(3),
318: FNDCP_TMSRV.P_RETURN_VALS(4),
319: FNDCP_TMSRV.P_RETURN_VALS(5),
320: FNDCP_TMSRV.P_RETURN_VALS(6),
321: FNDCP_TMSRV.P_RETURN_VALS(7),
322: FNDCP_TMSRV.P_RETURN_VALS(8),
323: FNDCP_TMSRV.P_RETURN_VALS(9),

Line 320: FNDCP_TMSRV.P_RETURN_VALS(6),

316: FNDCP_TMSRV.P_RETURN_VALS(2),
317: FNDCP_TMSRV.P_RETURN_VALS(3),
318: FNDCP_TMSRV.P_RETURN_VALS(4),
319: FNDCP_TMSRV.P_RETURN_VALS(5),
320: FNDCP_TMSRV.P_RETURN_VALS(6),
321: FNDCP_TMSRV.P_RETURN_VALS(7),
322: FNDCP_TMSRV.P_RETURN_VALS(8),
323: FNDCP_TMSRV.P_RETURN_VALS(9),
324: FNDCP_TMSRV.P_RETURN_VALS(10),

Line 321: FNDCP_TMSRV.P_RETURN_VALS(7),

317: FNDCP_TMSRV.P_RETURN_VALS(3),
318: FNDCP_TMSRV.P_RETURN_VALS(4),
319: FNDCP_TMSRV.P_RETURN_VALS(5),
320: FNDCP_TMSRV.P_RETURN_VALS(6),
321: FNDCP_TMSRV.P_RETURN_VALS(7),
322: FNDCP_TMSRV.P_RETURN_VALS(8),
323: FNDCP_TMSRV.P_RETURN_VALS(9),
324: FNDCP_TMSRV.P_RETURN_VALS(10),
325: FNDCP_TMSRV.P_RETURN_VALS(11),

Line 322: FNDCP_TMSRV.P_RETURN_VALS(8),

318: FNDCP_TMSRV.P_RETURN_VALS(4),
319: FNDCP_TMSRV.P_RETURN_VALS(5),
320: FNDCP_TMSRV.P_RETURN_VALS(6),
321: FNDCP_TMSRV.P_RETURN_VALS(7),
322: FNDCP_TMSRV.P_RETURN_VALS(8),
323: FNDCP_TMSRV.P_RETURN_VALS(9),
324: FNDCP_TMSRV.P_RETURN_VALS(10),
325: FNDCP_TMSRV.P_RETURN_VALS(11),
326: FNDCP_TMSRV.P_RETURN_VALS(12),

Line 323: FNDCP_TMSRV.P_RETURN_VALS(9),

319: FNDCP_TMSRV.P_RETURN_VALS(5),
320: FNDCP_TMSRV.P_RETURN_VALS(6),
321: FNDCP_TMSRV.P_RETURN_VALS(7),
322: FNDCP_TMSRV.P_RETURN_VALS(8),
323: FNDCP_TMSRV.P_RETURN_VALS(9),
324: FNDCP_TMSRV.P_RETURN_VALS(10),
325: FNDCP_TMSRV.P_RETURN_VALS(11),
326: FNDCP_TMSRV.P_RETURN_VALS(12),
327: FNDCP_TMSRV.P_RETURN_VALS(13),

Line 324: FNDCP_TMSRV.P_RETURN_VALS(10),

320: FNDCP_TMSRV.P_RETURN_VALS(6),
321: FNDCP_TMSRV.P_RETURN_VALS(7),
322: FNDCP_TMSRV.P_RETURN_VALS(8),
323: FNDCP_TMSRV.P_RETURN_VALS(9),
324: FNDCP_TMSRV.P_RETURN_VALS(10),
325: FNDCP_TMSRV.P_RETURN_VALS(11),
326: FNDCP_TMSRV.P_RETURN_VALS(12),
327: FNDCP_TMSRV.P_RETURN_VALS(13),
328: FNDCP_TMSRV.P_RETURN_VALS(14),

Line 325: FNDCP_TMSRV.P_RETURN_VALS(11),

321: FNDCP_TMSRV.P_RETURN_VALS(7),
322: FNDCP_TMSRV.P_RETURN_VALS(8),
323: FNDCP_TMSRV.P_RETURN_VALS(9),
324: FNDCP_TMSRV.P_RETURN_VALS(10),
325: FNDCP_TMSRV.P_RETURN_VALS(11),
326: FNDCP_TMSRV.P_RETURN_VALS(12),
327: FNDCP_TMSRV.P_RETURN_VALS(13),
328: FNDCP_TMSRV.P_RETURN_VALS(14),
329: FNDCP_TMSRV.P_RETURN_VALS(15),

Line 326: FNDCP_TMSRV.P_RETURN_VALS(12),

322: FNDCP_TMSRV.P_RETURN_VALS(8),
323: FNDCP_TMSRV.P_RETURN_VALS(9),
324: FNDCP_TMSRV.P_RETURN_VALS(10),
325: FNDCP_TMSRV.P_RETURN_VALS(11),
326: FNDCP_TMSRV.P_RETURN_VALS(12),
327: FNDCP_TMSRV.P_RETURN_VALS(13),
328: FNDCP_TMSRV.P_RETURN_VALS(14),
329: FNDCP_TMSRV.P_RETURN_VALS(15),
330: FNDCP_TMSRV.P_RETURN_VALS(16),

Line 327: FNDCP_TMSRV.P_RETURN_VALS(13),

323: FNDCP_TMSRV.P_RETURN_VALS(9),
324: FNDCP_TMSRV.P_RETURN_VALS(10),
325: FNDCP_TMSRV.P_RETURN_VALS(11),
326: FNDCP_TMSRV.P_RETURN_VALS(12),
327: FNDCP_TMSRV.P_RETURN_VALS(13),
328: FNDCP_TMSRV.P_RETURN_VALS(14),
329: FNDCP_TMSRV.P_RETURN_VALS(15),
330: FNDCP_TMSRV.P_RETURN_VALS(16),
331: FNDCP_TMSRV.P_RETURN_VALS(17),

Line 328: FNDCP_TMSRV.P_RETURN_VALS(14),

324: FNDCP_TMSRV.P_RETURN_VALS(10),
325: FNDCP_TMSRV.P_RETURN_VALS(11),
326: FNDCP_TMSRV.P_RETURN_VALS(12),
327: FNDCP_TMSRV.P_RETURN_VALS(13),
328: FNDCP_TMSRV.P_RETURN_VALS(14),
329: FNDCP_TMSRV.P_RETURN_VALS(15),
330: FNDCP_TMSRV.P_RETURN_VALS(16),
331: FNDCP_TMSRV.P_RETURN_VALS(17),
332: FNDCP_TMSRV.P_RETURN_VALS(18),

Line 329: FNDCP_TMSRV.P_RETURN_VALS(15),

325: FNDCP_TMSRV.P_RETURN_VALS(11),
326: FNDCP_TMSRV.P_RETURN_VALS(12),
327: FNDCP_TMSRV.P_RETURN_VALS(13),
328: FNDCP_TMSRV.P_RETURN_VALS(14),
329: FNDCP_TMSRV.P_RETURN_VALS(15),
330: FNDCP_TMSRV.P_RETURN_VALS(16),
331: FNDCP_TMSRV.P_RETURN_VALS(17),
332: FNDCP_TMSRV.P_RETURN_VALS(18),
333: FNDCP_TMSRV.P_RETURN_VALS(19),

Line 330: FNDCP_TMSRV.P_RETURN_VALS(16),

326: FNDCP_TMSRV.P_RETURN_VALS(12),
327: FNDCP_TMSRV.P_RETURN_VALS(13),
328: FNDCP_TMSRV.P_RETURN_VALS(14),
329: FNDCP_TMSRV.P_RETURN_VALS(15),
330: FNDCP_TMSRV.P_RETURN_VALS(16),
331: FNDCP_TMSRV.P_RETURN_VALS(17),
332: FNDCP_TMSRV.P_RETURN_VALS(18),
333: FNDCP_TMSRV.P_RETURN_VALS(19),
334: FNDCP_TMSRV.P_RETURN_VALS(20)

Line 331: FNDCP_TMSRV.P_RETURN_VALS(17),

327: FNDCP_TMSRV.P_RETURN_VALS(13),
328: FNDCP_TMSRV.P_RETURN_VALS(14),
329: FNDCP_TMSRV.P_RETURN_VALS(15),
330: FNDCP_TMSRV.P_RETURN_VALS(16),
331: FNDCP_TMSRV.P_RETURN_VALS(17),
332: FNDCP_TMSRV.P_RETURN_VALS(18),
333: FNDCP_TMSRV.P_RETURN_VALS(19),
334: FNDCP_TMSRV.P_RETURN_VALS(20)
335: );

Line 332: FNDCP_TMSRV.P_RETURN_VALS(18),

328: FNDCP_TMSRV.P_RETURN_VALS(14),
329: FNDCP_TMSRV.P_RETURN_VALS(15),
330: FNDCP_TMSRV.P_RETURN_VALS(16),
331: FNDCP_TMSRV.P_RETURN_VALS(17),
332: FNDCP_TMSRV.P_RETURN_VALS(18),
333: FNDCP_TMSRV.P_RETURN_VALS(19),
334: FNDCP_TMSRV.P_RETURN_VALS(20)
335: );
336:

Line 333: FNDCP_TMSRV.P_RETURN_VALS(19),

329: FNDCP_TMSRV.P_RETURN_VALS(15),
330: FNDCP_TMSRV.P_RETURN_VALS(16),
331: FNDCP_TMSRV.P_RETURN_VALS(17),
332: FNDCP_TMSRV.P_RETURN_VALS(18),
333: FNDCP_TMSRV.P_RETURN_VALS(19),
334: FNDCP_TMSRV.P_RETURN_VALS(20)
335: );
336:
337: msg_props.delay := DBMS_AQ.NO_DELAY;

Line 334: FNDCP_TMSRV.P_RETURN_VALS(20)

330: FNDCP_TMSRV.P_RETURN_VALS(16),
331: FNDCP_TMSRV.P_RETURN_VALS(17),
332: FNDCP_TMSRV.P_RETURN_VALS(18),
333: FNDCP_TMSRV.P_RETURN_VALS(19),
334: FNDCP_TMSRV.P_RETURN_VALS(20)
335: );
336:
337: msg_props.delay := DBMS_AQ.NO_DELAY;
338:

Line 353: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then

349: message_properties => msg_props,
350: Payload => msg,
351: msgid => msg_id);
352:
353: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then
354: fndcp_tmsrv.debug_info('TMSRV_QUEUE.write_message',
355: 'Sent Message' ,
356: reqid, 'S');
357:

Line 354: fndcp_tmsrv.debug_info('TMSRV_QUEUE.write_message',

350: Payload => msg,
351: msgid => msg_id);
352:
353: if ( P_DEBUG <> FNDCP_TMSRV.DBG_OFF ) then
354: fndcp_tmsrv.debug_info('TMSRV_QUEUE.write_message',
355: 'Sent Message' ,
356: reqid, 'S');
357:
358: end if;

Line 361: set_debug(FNDCP_TMSRV.DBG_OFF);

357:
358: end if;
359:
360: -- Turn off debug.
361: set_debug(FNDCP_TMSRV.DBG_OFF);
362:
363: -- Reset all the return values
364: for counter in 1..20 loop
365: FNDCP_TMSRV.P_RETURN_VALS(counter) := null;

Line 365: FNDCP_TMSRV.P_RETURN_VALS(counter) := null;

361: set_debug(FNDCP_TMSRV.DBG_OFF);
362:
363: -- Reset all the return values
364: for counter in 1..20 loop
365: FNDCP_TMSRV.P_RETURN_VALS(counter) := null;
366: end loop;
367:
368: exception
369: when OTHERS then

Line 370: e_code := FNDCP_TMSRV.E_OTHER;

366: end loop;
367:
368: exception
369: when OTHERS then
370: e_code := FNDCP_TMSRV.E_OTHER;
371: fnd_message.set_name ('FND', 'SQL-Generic error');
372: fnd_message.set_token ('ERRNO', sqlcode, FALSE);
373: fnd_message.set_token ('REASON', sqlerrm, FALSE);
374: fnd_message.set_token ('ROUTINE', 'TMSRV_QUEUE.COMPLETE_TRANS', FALSE);

Line 375: fndcp_tmsrv.debug_info('tmsrv_queue.complete_trans', 'Caught exception', sqlerrm);

371: fnd_message.set_name ('FND', 'SQL-Generic error');
372: fnd_message.set_token ('ERRNO', sqlcode, FALSE);
373: fnd_message.set_token ('REASON', sqlerrm, FALSE);
374: fnd_message.set_token ('ROUTINE', 'TMSRV_QUEUE.COMPLETE_TRANS', FALSE);
375: fndcp_tmsrv.debug_info('tmsrv_queue.complete_trans', 'Caught exception', sqlerrm);
376: raise;
377:
378: end write_message;
379: