DBA Data[Home] [Help]

APPS.XNP_TIMER_MGR dependencies on XNP_MESSAGE

Line 9: p_dummy_header IN xnp_message.msg_header_rec_type,

5:
6: /* forward declaration */
7:
8: PROCEDURE start_actual_timer( p_timer_code IN VARCHAR2,
9: p_dummy_header IN xnp_message.msg_header_rec_type,
10: p_dummy_text IN VARCHAR2,
11: x_error_code OUT NOCOPY NUMBER,
12: x_error_message OUT NOCOPY VARCHAR2);
13:

Line 15: p_msg_header IN xnp_message.msg_header_rec_type,

11: x_error_code OUT NOCOPY NUMBER,
12: x_error_message OUT NOCOPY VARCHAR2);
13:
14: PROCEDURE move_to_inbound(
15: p_msg_header IN xnp_message.msg_header_rec_type,
16: p_msg_text IN VARCHAR2,
17: x_error_code OUT NOCOPY NUMBER,
18: x_error_message OUT NOCOPY VARCHAR2);
19:

Line 38: l_msg_header xnp_message.msg_header_rec_type ;

34:
35: l_error_code NUMBER ;
36: l_error_message VARCHAR2(4000) ;
37:
38: l_msg_header xnp_message.msg_header_rec_type ;
39:
40: -- Change to CLOB
41:
42: l_msg_text VARCHAR2(32767) ;

Line 63: xnp_message.pop (p_queue_name => p_queue_name,

59: /* dequeue a message from the AQ */
60:
61: SAVEPOINT dequeue_timer ;
62:
63: xnp_message.pop (p_queue_name => p_queue_name,
64: x_msg_header => l_msg_header,
65: x_body_text => l_msg_text,
66: x_error_code => l_error_code,
67: x_error_message => l_error_message

Line 177: xnp_message.update_status(l_msg_header.message_id,

173: l_msg_header.message_id) ;
174:
175: l_fnd_message:= FND_MESSAGE.get ;
176:
177: xnp_message.update_status(l_msg_header.message_id,
178: 'FAILED',
179: l_fnd_message) ;
180:
181: WHEN timer_start_failed THEN

Line 199: xnp_message.update_status(l_msg_header.message_id,

195: l_error_message) ;
196:
197: l_fnd_message:= FND_MESSAGE.get ;
198:
199: xnp_message.update_status(l_msg_header.message_id,
200: 'FAILED',
201: l_fnd_message) ;
202:
203: WHEN failed_to_move_message THEN

Line 220: xnp_message.update_status(l_msg_header.message_id,

216: l_error_message) ;
217:
218: l_fnd_message:= FND_MESSAGE.get ;
219:
220: xnp_message.update_status(l_msg_header.message_id,
221: 'FAILED',
222: l_fnd_message) ;
223:
224: /* failed to update timer status in registry */

Line 243: xnp_message.update_status(l_msg_header.message_id,

239: l_error_message) ;
240:
241: l_fnd_message:= FND_MESSAGE.get ;
242:
243: xnp_message.update_status(l_msg_header.message_id,
244: 'FAILED',
245: l_fnd_message) ;
246: END process;
247:

Line 260: l_msg_header xnp_message.msg_header_rec_type ;

256:
257: l_error_code NUMBER ;
258: l_error_message VARCHAR2(4000) ;
259:
260: l_msg_header xnp_message.msg_header_rec_type ;
261:
262: -- Change to CLOB
263:
264: l_msg_text VARCHAR2(32767) ;

Line 285: xnp_message.pop (p_queue_name => p_queue_name,

281: /* dequeue a message from the AQ */
282:
283: SAVEPOINT dequeue_timer ;
284:
285: xnp_message.pop (p_queue_name => p_queue_name,
286: x_msg_header => l_msg_header,
287: x_body_text => l_msg_text,
288: x_error_code => l_error_code,
289: x_error_message => l_error_message,

Line 385: xnp_message.update_status(l_msg_header.message_id,

381: l_msg_header.message_id) ;
382:
383: l_fnd_message:= FND_MESSAGE.get ;
384:
385: xnp_message.update_status(l_msg_header.message_id,
386: 'FAILED',
387: l_fnd_message) ;
388:
389: WHEN timer_start_failed THEN

Line 407: xnp_message.update_status(l_msg_header.message_id,

403: l_error_message) ;
404:
405: l_fnd_message:= FND_MESSAGE.get ;
406:
407: xnp_message.update_status(l_msg_header.message_id,
408: 'FAILED',
409: l_fnd_message) ;
410:
411: WHEN failed_to_move_message THEN

Line 428: xnp_message.update_status(l_msg_header.message_id,

424: l_error_message) ;
425:
426: l_fnd_message:= FND_MESSAGE.get ;
427:
428: xnp_message.update_status(l_msg_header.message_id,
429: 'FAILED',
430: l_fnd_message) ;
431:
432: /* failed to update timer status in registry */

Line 451: xnp_message.update_status(l_msg_header.message_id,

447: l_error_message) ;
448:
449: l_fnd_message:= FND_MESSAGE.get ;
450:
451: xnp_message.update_status(l_msg_header.message_id,
452: 'FAILED',
453: l_fnd_message) ;
454: END process;
455:

Line 463: p_dummy_header IN xnp_message.msg_header_rec_type,

459: ***** Purpose: Starts the actual timer for a dummy.
460: ***********************************************************************/
461:
462: PROCEDURE start_actual_timer( p_timer_code IN VARCHAR2,
463: p_dummy_header IN xnp_message.msg_header_rec_type,
464: p_dummy_text IN VARCHAR2,
465: x_error_code OUT NOCOPY NUMBER,
466: x_error_message OUT NOCOPY VARCHAR2)
467:

Line 471: v_msg_header xnp_message.msg_header_rec_type ;

467:
468: IS
469:
470: l_msg_text VARCHAR2(32767);
471: v_msg_header xnp_message.msg_header_rec_type ;
472:
473: l_actual_interval_text VARCHAR2(80) ;
474: l_payload VARCHAR2(16000);
475: l_actual_interval NUMBER ;

Line 528: p_msg_header IN xnp_message.msg_header_rec_type,

524: ***** Purpose: Moves a message to inbound queue.
525: ***********************************************************************/
526:
527: PROCEDURE move_to_inbound(
528: p_msg_header IN xnp_message.msg_header_rec_type,
529: p_msg_text IN VARCHAR2,
530: x_error_code OUT NOCOPY NUMBER,
531: x_error_message OUT NOCOPY VARCHAR2)
532:

Line 534: l_message system.xnp_message_type ;

530: x_error_code OUT NOCOPY NUMBER,
531: x_error_message OUT NOCOPY VARCHAR2)
532:
533: IS
534: l_message system.xnp_message_type ;
535: l_msg_id XNP_MSGS.MSG_ID%TYPE ;
536: my_enqueue_options dbms_aq.enqueue_options_t ;
537: message_properties dbms_aq.message_properties_t ;
538: message_handle RAW(16) ;

Line 555: l_message := system.xnp_message_type(p_msg_header.message_id) ;

551:
552: -- my_enqueue_options.visibility := DBMS_AQ.IMMEDIATE ;
553: my_enqueue_options.visibility := DBMS_AQ.ON_COMMIT ;
554:
555: l_message := system.xnp_message_type(p_msg_header.message_id) ;
556:
557: DBMS_AQ.ENQUEUE (
558: queue_name => xnp_event.c_inbound_msg_q ,
559: enqueue_options => my_enqueue_options,

Line 571: p_old_msg_header IN xnp_message.msg_header_rec_type,

567: /*****************************************************************************/
568:
569: PROCEDURE construct_dynamic_message(
570: p_msg_to_create IN VARCHAR2,
571: p_old_msg_header IN xnp_message.msg_header_rec_type,
572: p_delay IN NUMBER DEFAULT NULL,
573: p_interval IN NUMBER DEFAULT NULL,
574: x_new_msg_header OUT NOCOPY xnp_message.msg_header_rec_type,
575: x_new_msg_text OUT NOCOPY VARCHAR2,

Line 574: x_new_msg_header OUT NOCOPY xnp_message.msg_header_rec_type,

570: p_msg_to_create IN VARCHAR2,
571: p_old_msg_header IN xnp_message.msg_header_rec_type,
572: p_delay IN NUMBER DEFAULT NULL,
573: p_interval IN NUMBER DEFAULT NULL,
574: x_new_msg_header OUT NOCOPY xnp_message.msg_header_rec_type,
575: x_new_msg_text OUT NOCOPY VARCHAR2,
576: x_error_code OUT NOCOPY NUMBER,
577: x_error_message OUT NOCOPY VARCHAR2)
578:

Line 591: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;

587: l_sql_block :=
588: '
589: BEGIN
590: DECLARE
591: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;
592: BEGIN
593: ' || g_new_line ;
594:
595: