DBA Data[Home] [Help]

APPS.XNP_TIMER_CORE dependencies on XNP_MESSAGE

Line 44: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;

40: l_status VARCHAR2(80);
41: l_start_time DATE;
42: l_elapsed_time NUMBER;
43: l_current_time DATE := sysdate;
44: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;
45: l_old_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;
46: l_msg_text VARCHAR2(32767);
47: l_new_interval NUMBER;
48: l_new_delay NUMBER;

Line 45: l_old_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;

41: l_start_time DATE;
42: l_elapsed_time NUMBER;
43: l_current_time DATE := sysdate;
44: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;
45: l_old_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;
46: l_msg_text VARCHAR2(32767);
47: l_new_interval NUMBER;
48: l_new_delay NUMBER;
49: l_interval_text VARCHAR2(40);

Line 89: xnp_message.get(

85: -- adabholk 03/2001
86: -- performance fix
87: -- new get() replaces two get calls
88:
89: xnp_message.get(
90: p_msg_id => l_timer_id
91: ,x_msg_header => l_old_msg_header
92: ,x_msg_text => l_msg_text);
93: /*

Line 94: -- xnp_message.get_header(

90: p_msg_id => l_timer_id
91: ,x_msg_header => l_old_msg_header
92: ,x_msg_text => l_msg_text);
93: /*
94: -- xnp_message.get_header(
95: -- p_msg_id => l_timer_id
96: -- ,x_msg_header => l_old_msg_header);
97: --
98: -- xnp_message.get(

Line 98: -- xnp_message.get(

94: -- xnp_message.get_header(
95: -- p_msg_id => l_timer_id
96: -- ,x_msg_header => l_old_msg_header);
97: --
98: -- xnp_message.get(
99: -- p_msg_id => l_timer_id
100: -- ,x_msg_text => l_msg_text);
101: */
102: -- Recalculate delay and interval

Line 178: xnp_message.get(

174: l_elapsed_time := round((l_current_time - l_start_time)*24*60*60);
175:
176: -- Recalculate delay and interval
177:
178: xnp_message.get(
179: p_msg_id => l_timer_id
180: ,x_msg_text => l_msg_text);
181:
182: xnp_xml_utils.decode(

Line 194: xnp_message.get_header(

190: l_new_delay := l_delay - l_elapsed_time;
191:
192: -- Construct timer with new_delay and interval
193:
194: xnp_message.get_header(
195: p_msg_id => l_timer_id
196: ,x_msg_header => l_old_msg_header);
197:
198: xnp_timer_mgr.construct_dynamic_message(

Line 531: l_message system.xnp_message_type ;

527: x_error_code OUT NOCOPY NUMBER,
528: x_error_message OUT NOCOPY VARCHAR2
529: )
530: IS
531: l_message system.xnp_message_type ;
532: l_message_id RAW(16) ;
533: l_msg_header xnp_message.msg_header_rec_type;
534: l_msg_text varchar2(32767) ;
535:

Line 533: l_msg_header xnp_message.msg_header_rec_type;

529: )
530: IS
531: l_message system.xnp_message_type ;
532: l_message_id RAW(16) ;
533: l_msg_header xnp_message.msg_header_rec_type;
534: l_msg_text varchar2(32767) ;
535:
536: BEGIN
537:

Line 538: l_message := system.xnp_message_type(p_timer_id) ;

534: l_msg_text varchar2(32767) ;
535:
536: BEGIN
537:
538: l_message := system.xnp_message_type(p_timer_id) ;
539:
540: SELECT msg_id INTO l_message_id
541: FROM aq$xnp_in_tmr_qtab
542: WHERE user_data = l_message ;

Line 546: xnp_message.pop(p_queue_name => xnp_event.c_timer_q,

542: WHERE user_data = l_message ;
543:
544: IF (l_message_id IS NOT NULL) THEN
545:
546: xnp_message.pop(p_queue_name => xnp_event.c_timer_q,
547: x_msg_header => l_msg_header,
548: x_body_text => l_msg_text,
549: x_error_code => x_error_code,
550: x_error_message => x_error_message,

Line 555: xnp_message.update_status(p_msg_id=>p_timer_id

551: p_msg_id => l_message_id );
552:
553: IF x_error_code = 0
554: THEN
555: xnp_message.update_status(p_msg_id=>p_timer_id
556: ,p_status=>'PROCESSED'
557: ,p_error_desc=>'Timer Removed') ;
558: END IF;
559:

Line 811: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;

807: l_timer_id NUMBER DEFAULT NULL;
808: l_next_timer_code VARCHAR2(80) DEFAULT NULL;
809: l_timer_code VARCHAR2(80) DEFAULT NULL;
810: l_status VARCHAR2(80);
811: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;
812: l_old_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;
813: l_msg_text VARCHAR2(32767);
814: l_msg_to_create VARCHAR2(80);
815:

Line 812: l_old_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;

808: l_next_timer_code VARCHAR2(80) DEFAULT NULL;
809: l_timer_code VARCHAR2(80) DEFAULT NULL;
810: l_status VARCHAR2(80);
811: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;
812: l_old_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;
813: l_msg_text VARCHAR2(32767);
814: l_msg_to_create VARCHAR2(80);
815:
816: l_EXCEPTION EXCEPTION; -- adabholk 06142000 for error trapping

Line 840: xnp_message.get_header(

836: IF x_error_code <> 0 THEN
837: raise l_EXCEPTION;
838: END IF;
839:
840: xnp_message.get_header(
841: p_msg_id => l_timer_id
842: ,x_msg_header => l_old_msg_header);
843:
844: -- Reconstruct the message

Line 939: l_old_msg_header xnp_message.msg_header_rec_type ;

935: SELECT timer_message_code
936: FROM xnp_timer_publishers
937: WHERE source_message_code = p_message_code ;
938:
939: l_old_msg_header xnp_message.msg_header_rec_type ;
940: l_new_msg_header xnp_message.msg_header_rec_type ;
941:
942: l_msg_text VARCHAR2(32767) ;
943:

Line 940: l_new_msg_header xnp_message.msg_header_rec_type ;

936: FROM xnp_timer_publishers
937: WHERE source_message_code = p_message_code ;
938:
939: l_old_msg_header xnp_message.msg_header_rec_type ;
940: l_new_msg_header xnp_message.msg_header_rec_type ;
941:
942: l_msg_text VARCHAR2(32767) ;
943:
944: BEGIN

Line 1066: l_pkg_name := XNP_MESSAGE.g_pkg_prefix || p_timer_code || XNP_MESSAGE.g_pkg_suffix;

1062: l_proc_call VARCHAR2(32767) := NULL;
1063:
1064: BEGIN
1065:
1066: l_pkg_name := XNP_MESSAGE.g_pkg_prefix || p_timer_code || XNP_MESSAGE.g_pkg_suffix;
1067: l_PROC_CALL :=
1068: 'BEGIN
1069: '||l_pkg_name||'.fire(' ||
1070: ' :x_timer_id' ||