DBA Data[Home] [Help]

APPS.XDP_AQ_UTILITIES dependencies on XNP_MESSAGE_TYPE

Line 3482: l_message SYSTEM.XNP_MESSAGE_TYPE ;

3478: x_msg_text VARCHAR2(32767);
3479: x_body_text VARCHAR2(32767);
3480: x_queue_timed_out VARCHAR2(1);
3481: l_msg_status VARCHAR2(40) ;
3482: l_message SYSTEM.XNP_MESSAGE_TYPE ;
3483: my_dequeue_options dbms_aq.dequeue_options_t ;
3484: message_properties dbms_aq.message_properties_t ;
3485: message_handle RAW(16) ;
3486: dq_time_out EXCEPTION;

Line 3587: l_message SYSTEM.XNP_MESSAGE_TYPE ;

3583: )
3584:
3585: IS
3586:
3587: l_message SYSTEM.XNP_MESSAGE_TYPE ;
3588: my_enqueue_options dbms_aq.enqueue_options_t ;
3589: message_properties dbms_aq.message_properties_t ;
3590: message_handle RAW(16) ;
3591: recipients dbms_aq.aq$_recipient_list_t ;

Line 3601: CURSOR get_consumer_name(l_msg system.xnp_message_type) IS

3597:
3598: l_correlation_id VARCHAR2(1024) ;
3599: l_msg_header xnp_message.msg_header_rec_type ;
3600:
3601: CURSOR get_consumer_name(l_msg system.xnp_message_type) IS
3602: SELECT consumer_name
3603: FROM AQ$XNP_OUT_MSG_QTAB a
3604: WHERE a.user_data = l_msg
3605: AND a.queue = 'XNP_OUT_MSG_EXCEPTION_Q';

Line 3629: l_message := SYSTEM.xnp_message_type( l_msg_header.message_id ) ;

3625: IF (p_delay IS NOT NULL) THEN
3626: message_properties.delay := p_delay ;
3627: END IF;
3628:
3629: l_message := SYSTEM.xnp_message_type( l_msg_header.message_id ) ;
3630:
3631: -- Use the correlation ID if one is specified
3632:
3633: IF ( l_correlation_id is NOT NULL ) THEN