DBA Data[Home] [Help]

APPS.XNP_MSG_BUILDER dependencies on XNP_MESSAGE

Line 730: || ' p_msg_header IN XNP_MESSAGE.MSG_HEADER_REC_TYPE,'

726: IS
727: BEGIN
728:
729: x_process_sig := x_process_sig || 'PROCEDURE PROCESS ( '
730: || ' p_msg_header IN XNP_MESSAGE.MSG_HEADER_REC_TYPE,'
731: || g_new_line
732: || ' p_msg_text IN VARCHAR2,' || g_new_line
733: || ' x_error_code OUT NUMBER,' || g_new_line
734: || ' x_error_message OUT VARCHAR2,' || g_new_line

Line 754: || ' p_msg_header IN XNP_MESSAGE.MSG_HEADER_REC_TYPE,'

750: BEGIN
751:
752: x_dflt_process_sig := x_dflt_process_sig
753: || 'PROCEDURE DEFAULT_PROCESS ( '
754: || ' p_msg_header IN XNP_MESSAGE.MSG_HEADER_REC_TYPE,'
755: || g_new_line
756: || ' p_msg_text IN VARCHAR2,' || g_new_line
757: || ' x_error_code OUT NUMBER,' || g_new_line
758: || ' x_error_message OUT VARCHAR2 ) ' ;

Line 776: || ' p_msg_header IN OUT XNP_MESSAGE.MSG_HEADER_REC_TYPE,'

772: IS
773: BEGIN
774:
775: x_validate_sig := x_validate_sig || 'PROCEDURE VALIDATE ( '
776: || ' p_msg_header IN OUT XNP_MESSAGE.MSG_HEADER_REC_TYPE,'
777: || g_new_line
778: || ' p_msg_text IN VARCHAR2,' || g_new_line
779: || ' x_error_code OUT NUMBER,' || g_new_line
780: || ' x_error_message OUT VARCHAR2 ) ' ;

Line 978: l_pkg_name := XNP_MESSAGE.g_pkg_prefix || g_message_code || XNP_MESSAGE.g_pkg_suffix;

974: -- l_pkg_name := g_pkg_prefix || g_message_code || g_pkg_suffix;
975: -- By Anping Wang, bug refer. 1650015
976: -- 02/19/2001
977:
978: l_pkg_name := XNP_MESSAGE.g_pkg_prefix || g_message_code || XNP_MESSAGE.g_pkg_suffix;
979:
980: xdp_utilities.build_pkg('CREATE OR REPLACE PACKAGE BODY ' || l_pkg_name || ' AS '
981: || g_new_line || g_new_line ) ;
982:

Line 1085: l_pkg_name := XNP_MESSAGE.g_pkg_prefix || g_message_code || XNP_MESSAGE.g_pkg_suffix ;

1081: -- 02/19/2001
1082: --
1083: xdp_utilities.initialize_pkg;
1084:
1085: l_pkg_name := XNP_MESSAGE.g_pkg_prefix || g_message_code || XNP_MESSAGE.g_pkg_suffix ;
1086:
1087:
1088: x_package_spec := x_package_spec
1089: || '/**************************************************************'

Line 1192: || ' l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;' || g_new_line ;

1188: x_publish_body := x_publish_body
1189: || ' l_queue_name VARCHAR2 (2000) ;' || g_new_line ;
1190:
1191: x_publish_body := x_publish_body
1192: || ' l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;' || g_new_line ;
1193:
1194: x_publish_body := x_publish_body
1195: || ' l_msg_text VARCHAR2(32767) ;' || g_new_line ;
1196:

Line 1218: || ' XNP_MESSAGE.GET_SUBSCRIBER_LIST( ' || ''''

1214: || g_new_line || g_new_line ;
1215:
1216: x_publish_body := x_publish_body || g_new_line
1217: || ' IF (l_consumer_list IS NULL) THEN' || g_new_line
1218: || ' XNP_MESSAGE.GET_SUBSCRIBER_LIST( ' || ''''
1219: || g_message_code || ''', '
1220: || 'l_consumer_list );' || g_new_line
1221: || ' END IF;' || g_new_line || g_new_line ;
1222:

Line 1282: || ' XNP_MESSAGE.push ( ' || g_new_line

1278: -- to .send() is made.
1279:
1280: x_publish_body := x_publish_body
1281: || ' IF (x_error_code = 0) THEN' || g_new_line
1282: || ' XNP_MESSAGE.push ( ' || g_new_line
1283: || ' p_msg_header => l_msg_header, ' || g_new_line
1284: || ' p_body_text => l_msg_text, ' || g_new_line
1285: || ' p_queue_name => xnp_event.c_outbound_msg_q, '
1286: || g_new_line

Line 1299: || ' XNP_MESSAGE.push ( ' || g_new_line

1295: || g_new_line ;
1296: ELSIF (UPPER(g_queue_name) = 'XNP_IN_MSG_Q') THEN
1297: x_publish_body := x_publish_body
1298: || ' IF (x_error_code = 0) THEN' || g_new_line||g_new_line
1299: || ' XNP_MESSAGE.push ( ' || g_new_line
1300: || ' p_msg_header => l_msg_header, ' || g_new_line
1301: || ' p_body_text => l_msg_text, ' || g_new_line
1302: || ' p_queue_name => xnp_event.c_inbound_msg_q, '
1303: || g_new_line

Line 1313: || ' XNP_MESSAGE.push ( ' || g_new_line

1309: || g_new_line ;
1310: ELSIF (UPPER(g_queue_name) = 'XNP_IN_EVT_Q') THEN
1311: x_publish_body := x_publish_body
1312: || ' IF (x_error_code = 0) THEN' || g_new_line||g_new_line
1313: || ' XNP_MESSAGE.push ( ' || g_new_line
1314: || ' p_msg_header => l_msg_header, ' || g_new_line
1315: || ' p_body_text => l_msg_text, ' || g_new_line
1316: || ' p_queue_name => xnp_event.c_internal_evt_q, '
1317: || g_new_line

Line 1327: || ' XNP_MESSAGE.push ( ' || g_new_line

1323: || g_new_line ;
1324: ELSIF (UPPER(g_queue_name) = 'XNP_IN_TMR_Q') THEN
1325: x_publish_body := x_publish_body
1326: || ' IF (x_error_code = 0) THEN' || g_new_line||g_new_line
1327: || ' XNP_MESSAGE.push ( ' || g_new_line
1328: || ' p_msg_header => l_msg_header, ' || g_new_line
1329: || ' p_body_text => l_msg_text, ' || g_new_line
1330: || ' p_queue_name => xnp_event.c_timer_q, '
1331: || g_new_line

Line 1340: || ' XNP_MESSAGE.PUSH_WF( ' || g_new_line

1336: || ' p_priority=>''' || g_msg_priority || ''', '
1337: || g_new_line ;
1338: ELSE x_publish_body := x_publish_body
1339: || ' IF (x_error_code = 0) THEN' || g_new_line||g_new_line
1340: || ' XNP_MESSAGE.PUSH_WF( ' || g_new_line
1341: || ' p_msg_header => l_msg_header, ' || g_new_line
1342: || ' p_body_text => l_msg_text, ' || g_new_line
1343: || ' p_queue_name => ''' || g_queue_name || ''', '
1344: || g_new_line

Line 1357: || ' p_commit_mode => XNP_MESSAGE.C_IMMEDIATE ); '

1353:
1354:
1355: IF (g_ack_reqd_flag = 'Y') THEN
1356: x_publish_body := x_publish_body
1357: || ' p_commit_mode => XNP_MESSAGE.C_IMMEDIATE ); '
1358: || g_new_line ;
1359: ELSE
1360: x_publish_body := x_publish_body
1361: || ' p_commit_mode => XNP_MESSAGE.C_ON_COMMIT ); '

Line 1361: || ' p_commit_mode => XNP_MESSAGE.C_ON_COMMIT ); '

1357: || ' p_commit_mode => XNP_MESSAGE.C_IMMEDIATE ); '
1358: || g_new_line ;
1359: ELSE
1360: x_publish_body := x_publish_body
1361: || ' p_commit_mode => XNP_MESSAGE.C_ON_COMMIT ); '
1362: || g_new_line ;
1363: END IF ;
1364:
1365: x_publish_body := x_publish_body || g_new_line

Line 1380: || ' XNP_MESSAGE.push ( ' || g_new_line

1376: IF UPPER(g_queue_name) like 'XNP%' THEN
1377:
1378: x_publish_body := x_publish_body
1379: || ' IF (x_error_code = 0) THEN' || g_new_line||g_new_line
1380: || ' XNP_MESSAGE.push ( ' || g_new_line
1381: || ' p_msg_header => l_msg_header, ' || g_new_line
1382: || ' p_body_text => l_msg_text, ' || g_new_line
1383: || ' p_queue_name => xnp_event.c_internal_evt_q, '
1384: || g_new_line

Line 1395: || ' XNP_MESSAGE.PUSH_WF( ' || g_new_line

1391:
1392: ELSE
1393: x_publish_body := x_publish_body
1394: || ' IF (x_error_code = 0) THEN' || g_new_line||g_new_line
1395: || ' XNP_MESSAGE.PUSH_WF( ' || g_new_line
1396: || ' p_msg_header => l_msg_header, ' || g_new_line
1397: || ' p_body_text => l_msg_text, ' || g_new_line
1398: || ' p_queue_name => ''' || g_queue_name || ''', '
1399: || g_new_line

Line 1409: || ' p_commit_mode => XNP_MESSAGE.C_IMMEDIATE ); '

1405: END IF;
1406:
1407: IF (g_ack_reqd_flag = 'Y') THEN
1408: x_publish_body := x_publish_body
1409: || ' p_commit_mode => XNP_MESSAGE.C_IMMEDIATE ); '
1410: || g_new_line ;
1411: ELSE
1412: x_publish_body := x_publish_body
1413: || ' p_commit_mode => XNP_MESSAGE.C_ON_COMMIT ); '

Line 1413: || ' p_commit_mode => XNP_MESSAGE.C_ON_COMMIT ); '

1409: || ' p_commit_mode => XNP_MESSAGE.C_IMMEDIATE ); '
1410: || g_new_line ;
1411: ELSE
1412: x_publish_body := x_publish_body
1413: || ' p_commit_mode => XNP_MESSAGE.C_ON_COMMIT ); '
1414: || g_new_line ;
1415: END IF ;
1416:
1417: x_publish_body := x_publish_body

Line 1419: || ' XNP_MESSAGE.GET_SEQUENCE(l_msg_header.message_id) ;'

1415: END IF ;
1416:
1417: x_publish_body := x_publish_body
1418: || ' IF (l_consumer_list IS NOT NULL) THEN' || g_new_line
1419: || ' XNP_MESSAGE.GET_SEQUENCE(l_msg_header.message_id) ;'
1420: || g_new_line ||g_new_line
1421: || ' l_msg_header.direction_indr := '||''''||'O'||''''||';'
1422: || g_new_line ||g_new_line
1423: || ' XNP_MESSAGE.push ( ' || g_new_line

Line 1423: || ' XNP_MESSAGE.push ( ' || g_new_line

1419: || ' XNP_MESSAGE.GET_SEQUENCE(l_msg_header.message_id) ;'
1420: || g_new_line ||g_new_line
1421: || ' l_msg_header.direction_indr := '||''''||'O'||''''||';'
1422: || g_new_line ||g_new_line
1423: || ' XNP_MESSAGE.push ( ' || g_new_line
1424: || ' p_msg_header => l_msg_header, ' || g_new_line
1425: || ' p_body_text => l_msg_text, ' || g_new_line
1426: || ' p_queue_name => xnp_event.c_outbound_msg_q, '
1427: || g_new_line

Line 1571: || ' x_msg_header OUT XNP_MESSAGE.MSG_HEADER_REC_TYPE,' || g_new_line

1567:
1568: END LOOP ;
1569:
1570: x_create_sig := x_create_sig
1571: || ' x_msg_header OUT XNP_MESSAGE.MSG_HEADER_REC_TYPE,' || g_new_line
1572: || ' x_msg_text OUT VARCHAR2,' || g_new_line
1573: || ' x_error_code OUT NUMBER,' || g_new_line
1574: || ' x_error_message OUT VARCHAR2,' || g_new_line
1575: || ' p_sender_name IN VARCHAR2 DEFAULT NULL,' || g_new_line

Line 2272: || ' FOR ' || XNP_MESSAGE.g_pkg_prefix || g_message_code

2268: -- || ' FOR ' || g_pkg_prefix || g_message_code
2269: -- || g_pkg_suffix ;
2270: --
2271: l_sql_text := 'CREATE SYNONYM ' || g_message_code
2272: || ' FOR ' || XNP_MESSAGE.g_pkg_prefix || g_message_code
2273: || XNP_MESSAGE.g_pkg_suffix ;
2274:
2275: x_synonym := l_sql_text ;
2276:

Line 2273: || XNP_MESSAGE.g_pkg_suffix ;

2269: -- || g_pkg_suffix ;
2270: --
2271: l_sql_text := 'CREATE SYNONYM ' || g_message_code
2272: || ' FOR ' || XNP_MESSAGE.g_pkg_prefix || g_message_code
2273: || XNP_MESSAGE.g_pkg_suffix ;
2274:
2275: x_synonym := l_sql_text ;
2276:
2277: AD_DDL.DO_DDL(

Line 2320: || 'l_ack_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;'

2316:
2317: IF (UPPER(g_queue_name) = 'XNP_OUT_MSG_Q') THEN
2318:
2319: x_send_body := x_send_body
2320: || 'l_ack_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;'
2321: || g_new_line
2322: || 'l_ack_code VARCHAR2(40);' || g_new_line
2323: || 'l_error_code NUMBER ;'
2324: || 'l_error_message VARCHAR2(512);' || g_new_line

Line 2381: || ' XNP_MESSAGE.POP ( '

2377: || '****/' || g_new_line || g_new_line ;
2378:
2379: x_send_body := x_send_body
2380: || ' IF (x_error_code = 0) THEN' || g_new_line || g_new_line
2381: || ' XNP_MESSAGE.POP ( '
2382: || ' p_queue_name => xnp_event.c_inbound_msg_q, '
2383: || g_new_line
2384: || ' x_msg_header => l_ack_header,' || g_new_line
2385: || ' x_body_text => l_ack_msg,' || g_new_line

Line 2401: || ' XNP_MESSAGE.UPDATE_STATUS(x_message_id, '

2397: || 'DESCRIPTION' || ''',' || 'x_error_message) ;'
2398: || g_new_line
2399: || ' x_error_code := TO_NUMBER(l_ack_code) ;' || g_new_line
2400: || ' ELSE' || g_new_line
2401: || ' XNP_MESSAGE.UPDATE_STATUS(x_message_id, '
2402: || '''' || 'TIMEOUT' || ''');' || g_new_line
2403: || ' END IF ;' || g_new_line || g_new_line
2404: || ' END IF;' || g_new_line || g_new_line ;
2405:

Line 2474: l_msg_header xnp_message.msg_header_rec_type ;

2470: l_start_body := l_start_sig ||
2471: '
2472: IS
2473:
2474: l_msg_header xnp_message.msg_header_rec_type ;
2475: l_msg_text VARCHAR2(32767);
2476: ' || g_new_line || g_new_line;
2477:
2478: l_start_body := l_start_body ||

Line 2615: || ' l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;' || g_new_line ;

2611: g_decl_section := g_decl_section
2612: || ' l_xml_header VARCHAR2(32767) ;' || g_new_line ;
2613:
2614: g_decl_section := g_decl_section
2615: || ' l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;' || g_new_line ;
2616:
2617:
2618: /* Build create body and add it to the global table of records */
2619:

Line 2634: g_temp_tab(g_temp_tab.COUNT + 1 ) := ' XNP_MESSAGE.get_sequence ( l_msg_header.message_id ) ;'

2630:
2631: g_temp_tab(g_temp_tab.COUNT + 1 ) := '/*construct the XML header */' || g_new_line ;
2632: g_temp_tab(g_temp_tab.COUNT + 1 ) := '/* retreive the next message ID */' || g_new_line ;
2633:
2634: g_temp_tab(g_temp_tab.COUNT + 1 ) := ' XNP_MESSAGE.get_sequence ( l_msg_header.message_id ) ;'
2635: || g_new_line;
2636: g_temp_tab(g_temp_tab.COUNT + 1 ) := ' IF (p_reference_id IS NULL) THEN' ;
2637: g_temp_tab(g_temp_tab.COUNT + 1 ) := ' l_msg_header.reference_id := l_msg_header.message_id ;';
2638: g_temp_tab(g_temp_tab.COUNT + 1 ) := ' ELSE' ;