APPS.XDP_AQ_UTILITIES dependencies on XNP_EVENT

Line 2553: XNP_EVENT.PROCESS_IN_EVT( p_message_wait_timeout => g_msg_wait_timeout,

2549:
2550: FOR i IN 1..G_DQ_COUNT
2551:
2552: LOOP
2553: XNP_EVENT.PROCESS_IN_EVT( p_message_wait_timeout => g_msg_wait_timeout,
2554: p_correlation_id => null,
2555: x_message_key => l_message_key,
2556: x_queue_timed_out => l_time_out );
2557:

Line 2597: XNP_EVENT.PROCESS_IN_MSG( p_message_wait_timeout => g_msg_wait_timeout,

2593:
2594: FOR i IN 1..G_DQ_COUNT
2595:
2596: LOOP
2597: XNP_EVENT.PROCESS_IN_MSG( p_message_wait_timeout => g_msg_wait_timeout,
2598: p_correlation_id => null,
2599: x_message_key => l_message_key,
2600: x_queue_timed_out => l_time_out );
2601:

Line 3326: p_queue_name => xnp_event.c_inbound_msg_q ,

3322: ELSE
3323:
3324: ReENQUEUE( p_msg_header => l_msg_header ,
3325: p_body_text => l_body_text ,
3326: p_queue_name => xnp_event.c_inbound_msg_q ,
3327: p_correlation_id => l_msg_header.message_code ,
3328: p_commit_mode => xnp_message.c_on_commit );
3329:
3330: END IF ;

Line 3390: p_queue_name => xnp_event.c_internal_evt_q ,

3386: ELSE
3387:
3388: ReENQUEUE( p_msg_header => l_msg_header ,
3389: p_body_text => l_body_text ,
3390: p_queue_name => xnp_event.c_internal_evt_q ,
3391: p_correlation_id => l_msg_header.message_code ,
3392: p_commit_mode => xnp_message.c_on_commit );
3393:
3394: END IF ;

Line 3452: p_queue_name => xnp_event.c_timer_q ,

3448: ELSE
3449:
3450: ReENQUEUE( p_msg_header => l_msg_header ,
3451: p_body_text => l_body_text ,
3452: p_queue_name => xnp_event.c_timer_q ,
3453: p_priority => 1 ,
3454: p_commit_mode => xnp_message.c_on_commit);
3455:
3456: END IF ;

Line 3546: p_queue_name => xnp_event.c_outbound_msg_q ,

3542: ELSE
3543:
3544: ReENQUEUE( p_msg_header => x_msg_header ,
3545: p_body_text => x_body_text ,
3546: p_queue_name => xnp_event.c_outbound_msg_q ,
3547: p_correlation_id => x_msg_header.message_code ,
3548: p_commit_mode => xnp_message.c_on_commit);
3549:
3550: END IF ;

Line 3642: IF( p_queue_name = xnp_event.c_outbound_msg_q ) THEN

3638: -- Check if there are recipients, if there is no recipient, simply enqueue the
3639: -- message on the specified queue
3640: --
3641:
3642: IF( p_queue_name = xnp_event.c_outbound_msg_q ) THEN
3643:
3644: l_recipient_count := 1;
3645:
3646: FOR rec in get_consumer_name(l_message)