[Home] [Help]
1: PACKAGE BODY xnp_message AS
2: /* $Header: XNPMSGPB.pls 120.2 2006/02/24 17:57:16 sacsharm noship $ */
3:
4: e_procedure_exec_error EXCEPTION ;
5: -- g_schema_set NUMBER := 0;
14: substr(userenv('LANGUAGE'), instr(userenv('LANGUAGE'),'.') +1),
15: 'WE8ISO8859P1') ;
16:
17: PROCEDURE decode_xnp_msgs (
18: p_msg_header IN OUT NOCOPY XNP_MESSAGE.MSG_HEADER_REC_TYPE,
19: p_body_text IN VARCHAR2
20: ) ;
21:
22: PROCEDURE check_run_time_data(
104: x_error_message := NULL ;
105:
106: l_sql:= 'BEGIN
107: DECLARE
108: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;
109: BEGIN
110: l_msg_header.message_id := :message_id ;
111: l_msg_header.message_code := :message_code ;
112: l_msg_header.reference_id := :reference_id ;
176:
177:
178: l_sql:= 'BEGIN
179: DECLARE
180: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;
181: BEGIN
182: l_msg_header.message_id := :message_id ;
183: l_msg_header.message_code := :message_code ;
184: l_msg_header.reference_id := :reference_id ;
243:
244:
245: l_sql:= 'BEGIN
246: DECLARE
247: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;
248: BEGIN
249: l_msg_header.message_id := :message_id ;
250: l_msg_header.message_code := :message_code ;
251: l_msg_header.reference_id := :reference_id ;
448: ,p_adapter_name IN VARCHAR2 DEFAULT NULL
449: )
450: IS
451:
452: l_message SYSTEM.XNP_MESSAGE_TYPE ;
453: my_enqueue_options dbms_aq.enqueue_options_t ;
454: message_properties dbms_aq.message_properties_t ;
455: message_handle RAW(16) ;
456: recipients dbms_aq.aq$_recipient_list_t ;
465:
466: l_adapter_name XNP_MSGS.ADAPTER_NAME%TYPE;
467: l_fe_name XNP_MSGS.FE_NAME%TYPE;
468:
469: l_msg_header xnp_message.msg_header_rec_type ;
470: l_temp_fe NUMBER;
471: l_temp_adapter NUMBER;
472: BEGIN
473:
536: l_correlation_id := l_msg_header.message_code ;
537:
538:
539: IF ( l_msg_header.message_id IS NULL ) THEN
540: XNP_MESSAGE.get_sequence(l_msg_header.message_id) ;
541: END IF ;
542:
543: IF (((l_msg_header.direction_indr = 'I') OR
544: (l_msg_header.direction_indr IS NULL)) AND
623: IF (p_delay IS NOT NULL) THEN
624: message_properties.delay := p_delay ;
625: END IF;
626:
627: l_message := SYSTEM.xnp_message_type( l_msg_header.message_id ) ;
628:
629: --
630: -- check if there is a recipient, if there is no recipient, simply enqueue the
631: -- message on the specified queue
752: ,p_priority IN INTEGER DEFAULT 1
753: ,p_commit_mode IN NUMBER DEFAULT c_on_commit
754: )
755: IS
756: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;
757:
758: BEGIN
759:
760: l_msg_header.message_id := p_message_id ;
805: )
806: IS
807:
808: l_msg_status VARCHAR2(40) ;
809: l_message SYSTEM.XNP_MESSAGE_TYPE ;
810: my_dequeue_options dbms_aq.dequeue_options_t ;
811: message_properties dbms_aq.message_properties_t ;
812: message_handle RAW(16) ;
813: l_timeout NUMBER ;
914: -- adabholk 03/2001
915: -- performance fix
916: -- new get() replaces two get calls
917:
918: xnp_message.get(
919: p_msg_id => l_message.message_id
920: ,x_msg_header => x_msg_header
921: ,x_msg_text => x_body_text);
922: /*
1014: ,p_correlation_id IN VARCHAR2 DEFAULT NULL
1015: )
1016: IS
1017:
1018: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;
1019:
1020: BEGIN
1021:
1022: x_error_code := 0 ;
1435: PROCEDURE fix (
1436: P_MSG_ID IN NUMBER
1437: )
1438: IS
1439: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;
1440: l_msg_text VARCHAR2(32767) ;
1441:
1442: l_message SYSTEM.XNP_MESSAGE_TYPE ;
1443: l_msg_id XNP_MSGS.MSG_ID%TYPE ;
1438: IS
1439: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE ;
1440: l_msg_text VARCHAR2(32767) ;
1441:
1442: l_message SYSTEM.XNP_MESSAGE_TYPE ;
1443: l_msg_id XNP_MSGS.MSG_ID%TYPE ;
1444: my_enqueue_options dbms_aq.enqueue_options_t ;
1445: message_properties dbms_aq.message_properties_t ;
1446: message_handle RAW(16) ;
1462: -- message_properties.correlation := 'MSG_SERVER' ;
1463: message_properties.correlation := l_msg_header.message_code;
1464: my_enqueue_options.visibility := DBMS_AQ.ON_COMMIT ;
1465:
1466: l_message := SYSTEM.xnp_message_type(p_msg_id) ;
1467:
1468: DBMS_AQ.ENQUEUE (
1469: queue_name => XNP_EVENT.C_INBOUND_MSG_Q ,
1470: enqueue_options => my_enqueue_options,
1494: and populates the columns in XNP_MSGS table
1495: **************************************************************************/
1496:
1497: PROCEDURE decode_xnp_msgs (
1498: p_msg_header IN OUT NOCOPY xnp_message.msg_header_rec_type,
1499: p_body_text IN VARCHAR2
1500: ) IS
1501: l_creation_date VARCHAR2(512) ;
1502: l_header VARCHAR2(4000) ;
1586: -- l_performer := xdp_utilities.get_wf_notifrecipient(l_role_name) ;
1587:
1588: l_item_type := 'XDPWFSTD' ;
1589:
1590: xnp_message.get_sequence(l_msg_id) ;
1591:
1592: l_item_key := 'MESSAGE_' || TO_CHAR(p_msg_id) ||
1593: TO_CHAR(l_msg_id) ;
1594:
1678: x_error_message := 'Message Code or Name Required' ;
1679: return ;
1680: END IF ;
1681:
1682: xnp_message.get_sequence(l_msg_header.message_id) ;
1683: l_msg_header.direction_indr := 'I' ;
1684: xnp_xml_utils.decode(p_msg_text, 'REFERENCE_ID',
1685: l_msg_header.reference_id) ;
1686: xnp_xml_utils.decode(p_msg_text, 'OPP_REFERENCE_ID',
2029:
2030: l_lob_loc CLOB ;
2031: l_correlation_id VARCHAR2(1024) ;
2032:
2033: l_msg_header xnp_message.msg_header_rec_type ;
2034: x_error_message varchar2(4000);
2035: x_error_code number;
2036:
2037: BEGIN
2040: l_correlation_id := l_msg_header.message_code ;
2041: message_properties.priority := p_priority;
2042:
2043: IF ( l_msg_header.message_id IS NULL ) THEN
2044: XNP_MESSAGE.get_sequence(l_msg_header.message_id) ;
2045: END IF ;
2046:
2047: -- Use the correlation ID if one is specified
2048:
2130: 'XNPMSGPB'||to_char(g_logdate, 'YYYYMMDDHHMISS')||'.out',
2131: g_logdir);
2132: END IF;
2133:
2134: END xnp_message;
2135: