eTRM uses javascript that opens and focuses a separate window to display reports. Your browser does not appear to support javascript. This should not prevent you from using eTRM but it does mean the window focus feature will not work. Please check the contents of other windows on your desktop if you click on a link that does not appear to do anything.

APPS.XDP_AQ_UTILITIES dependencies on XNP_MESSAGE

Line 337: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;

333: lv_DequeueOptions.MSGID := v_GetPendingOrders.msgid;
334:
335: BEGIN
336: -- Set Dequeue time out to be 1 second
337: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;
338: DBMS_AQ.DEQUEUE(
339: queue_name => G_XDP_SCHEMA||'.'||'XDP_PENDING_ORDER_QUEUE',
340: dequeue_options => lv_DequeueOptions,
341: message_properties => lv_MessageProperties,

Line 726: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;

722: lv_DequeueOptions.MSGID := NULL;
723:
724: BEGIN
725: -- Set Dequeue time out to be 1 second
726: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;
727:
728: DBMS_AQ.DEQUEUE(
729: queue_name => G_XDP_SCHEMA||'.'||'XDP_ORDER_PROC_QUEUE',
730: dequeue_options => lv_DequeueOptions,

Line 1013: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;

1009: lv_DequeueOptions.MSGID := NULL;
1010:
1011: BEGIN
1012: -- Set Dequeue time out to be 1 second
1013: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;
1014:
1015: DBMS_AQ.DEQUEUE( queue_name => G_XDP_SCHEMA||'.'||'XDP_WORKITEM_QUEUE',
1016: dequeue_options => lv_DequeueOptions,
1017: message_properties => lv_MessageProperties,

Line 1314: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;

1310: lv_DequeueOptions.MSGID := NULL;
1311:
1312: BEGIN
1313: -- Set Dequeue time out to be 1 second
1314: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;
1315:
1316: DBMS_AQ.DEQUEUE( queue_name => G_XDP_SCHEMA||'.'||'XDP_FA_QUEUE',
1317: dequeue_options => lv_DequeueOptions,
1318: message_properties => lv_MessageProperties,

Line 1577: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;

1573: lv_DequeueOptions.visibility := DBMS_AQ.ON_COMMIT;
1574: lv_DequeueOptions.navigation := DBMS_AQ.NEXT_MESSAGE;
1575:
1576: -- Set Dequeue time out to be 1 second
1577: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;
1578: BEGIN
1579:
1580: DBMS_AQ.DEQUEUE( queue_name => G_XDP_SCHEMA||'.'||'XDP_WF_Channel_Q',
1581: dequeue_options => lv_DequeueOptions,

Line 1592: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;

1588: lv_DequeueOptions.navigation := DBMS_AQ.FIRST_MESSAGE;
1589: lv_DequeueOptions.visibility := DBMS_AQ.ON_COMMIT;
1590:
1591: -- Set Dequeue time out to be 1 second
1592: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;
1593: DBMS_AQ.DEQUEUE( queue_name => G_XDP_SCHEMA||'.'||'XDP_WF_Channel_Q',
1594: dequeue_options => lv_DequeueOptions,
1595: message_properties => lv_MessageProperties,
1596: payload => lv_wf_object,

Line 1914: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;

1910: lv_DequeueOptions.visibility := DBMS_AQ.ON_COMMIT;
1911: lv_DequeueOptions.navigation := DBMS_AQ.NEXT_MESSAGE;
1912:
1913: -- Set Dequeue time out to be 2 second
1914: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;
1915: BEGIN
1916: DBMS_AQ.DEQUEUE(
1917: queue_name => G_XDP_SCHEMA||'.'||'XDP_WF_SEQUENCING_Q',
1918: dequeue_options => lv_DequeueOptions,

Line 1929: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;

1925: lv_DequeueOptions.visibility := DBMS_AQ.ON_COMMIT;
1926: lv_DequeueOptions.navigation := DBMS_AQ.FIRST_MESSAGE;
1927:
1928: -- Set Dequeue time out to be 2 second
1929: lv_DequeueOptions.wait := xnp_message.POP_TIMEOUT;
1930: DBMS_AQ.DEQUEUE(
1931: queue_name => G_XDP_SCHEMA||'.'||'XDP_WF_SEQUENCING_Q',
1932: dequeue_options => lv_DequeueOptions,
1933: message_properties => lv_MessageProperties,

Line 3291: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;

3287:
3288: l_dq_count NUMBER ;
3289: l_error_code NUMBER;
3290: l_error_message VARCHAR2(4000);
3291: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;
3292: l_msg_text VARCHAR2(32767);
3293: l_body_text VARCHAR2(32767);
3294: x_queue_timed_out VARCHAR2(1);
3295:

Line 3308: XNP_MESSAGE.POP( p_queue_name => G_XNP_SCHEMA ||'.'||'XNP_IN_MSG_EXCEPTION_Q',

3304:
3305: FOR i IN 1..G_DQ_COUNT
3306: LOOP
3307:
3308: XNP_MESSAGE.POP( p_queue_name => G_XNP_SCHEMA ||'.'||'XNP_IN_MSG_EXCEPTION_Q',
3309: x_msg_header => l_msg_header,
3310: x_body_text => l_body_text,
3311: x_error_code => l_error_code,
3312: x_error_message => l_error_message

Line 3328: p_commit_mode => xnp_message.c_on_commit );

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 ;
3331:
3332: l_dq_count := l_dq_count + 1 ;

Line 3355: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;

3351:
3352: l_dq_count NUMBER ;
3353: l_error_code NUMBER;
3354: l_error_message VARCHAR2(4000);
3355: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;
3356: l_msg_text VARCHAR2(32767);
3357: l_body_text VARCHAR2(32767);
3358: x_queue_timed_out VARCHAR2(1);
3359:

Line 3372: XNP_MESSAGE.POP( p_queue_name => G_XNP_SCHEMA ||'.'||'XNP_IN_EVT_EXCEPTION_Q',

3368:
3369: FOR i IN 1..G_DQ_COUNT
3370: LOOP
3371:
3372: XNP_MESSAGE.POP( p_queue_name => G_XNP_SCHEMA ||'.'||'XNP_IN_EVT_EXCEPTION_Q',
3373: x_msg_header => l_msg_header,
3374: x_body_text => l_body_text,
3375: x_error_code => l_error_code,
3376: x_error_message => l_error_message

Line 3392: p_commit_mode => xnp_message.c_on_commit );

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 ;
3395: l_dq_count := l_dq_count + 1 ;
3396: DBMS_LOCK.SLEEP(g_sleep_time);

Line 3417: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;

3413:
3414: l_dq_count NUMBER ;
3415: l_error_code NUMBER;
3416: l_error_message VARCHAR2(4000);
3417: l_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;
3418: l_msg_text VARCHAR2(32767);
3419: l_body_text VARCHAR2(32767);
3420: x_queue_timed_out VARCHAR2(1);
3421:

Line 3434: XNP_MESSAGE.POP( p_queue_name => G_XNP_SCHEMA ||'.'||'XNP_IN_TMR_EXCEPTION_Q',

3430:
3431: FOR i IN 1..G_DQ_COUNT
3432: LOOP
3433:
3434: XNP_MESSAGE.POP( p_queue_name => G_XNP_SCHEMA ||'.'||'XNP_IN_TMR_EXCEPTION_Q',
3435: x_msg_header => l_msg_header,
3436: x_body_text => l_body_text,
3437: x_error_code => l_error_code,
3438: x_error_message => l_error_message

Line 3454: p_commit_mode => xnp_message.c_on_commit);

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 ;
3457: l_dq_count := l_dq_count + 1 ;
3458: DBMS_LOCK.SLEEP(g_sleep_time);

Line 3477: x_msg_header XNP_MESSAGE.MSG_HEADER_REC_TYPE;

3473:
3474: IS
3475:
3476: l_dq_count NUMBER ;
3477: x_msg_header XNP_MESSAGE.MSG_HEADER_REC_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) ;

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 3520: xnp_message.get_status(l_message.message_id, l_msg_status);

3516: payload => l_message,
3517: msgid => message_handle );
3518:
3519: x_msg_header.message_id := l_message.message_id;
3520: xnp_message.get_status(l_message.message_id, l_msg_status);
3521:
3522: IF ( l_msg_status = 'READY' OR l_msg_status = 'PROCESSED' ) THEN
3523:
3524: xnp_message.get(

Line 3524: xnp_message.get(

3520: xnp_message.get_status(l_message.message_id, l_msg_status);
3521:
3522: IF ( l_msg_status = 'READY' OR l_msg_status = 'PROCESSED' ) THEN
3523:
3524: xnp_message.get(
3525: p_msg_id => l_message.message_id
3526: ,x_msg_header => x_msg_header
3527: ,x_msg_text => x_body_text);
3528:

Line 3548: p_commit_mode => xnp_message.c_on_commit);

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 ;
3551: my_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE_NODATA;
3552: my_dequeue_options.msgid := message_handle;

Line 3576: PROCEDURE ReENQUEUE( p_msg_header IN XNP_MESSAGE.MSG_HEADER_REC_TYPE

3572:
3573: END DQ_XNP_OUT_MSG_REENQ;
3574:
3575:
3576: PROCEDURE ReENQUEUE( p_msg_header IN XNP_MESSAGE.MSG_HEADER_REC_TYPE
3577: ,p_body_text IN VARCHAR2
3578: ,p_queue_name IN VARCHAR2
3579: ,p_correlation_id IN VARCHAR2 DEFAULT NULL
3580: ,p_priority IN INTEGER DEFAULT 1

Line 3581: ,p_commit_mode IN NUMBER DEFAULT XNP_MESSAGE.C_ON_COMMIT

3577: ,p_body_text IN VARCHAR2
3578: ,p_queue_name IN VARCHAR2
3579: ,p_correlation_id IN VARCHAR2 DEFAULT NULL
3580: ,p_priority IN INTEGER DEFAULT 1
3581: ,p_commit_mode IN NUMBER DEFAULT XNP_MESSAGE.C_ON_COMMIT
3582: ,p_delay IN NUMBER DEFAULT DBMS_AQ.NO_DELAY
3583: )
3584:
3585: IS

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 3599: l_msg_header xnp_message.msg_header_rec_type ;

3595: l_initial_pos INTEGER ;
3596: l_delimeter_pos INTEGER ;
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

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 3617: IF (p_commit_mode = XNP_MESSAGE.C_IMMEDIATE) THEN

3613: SET msg_status = 'READY',
3614: last_update_date = SYSDATE
3615: WHERE msg_id = l_msg_header.message_id;
3616:
3617: IF (p_commit_mode = XNP_MESSAGE.C_IMMEDIATE) THEN
3618: COMMIT ;
3619: END IF ;
3620:
3621: IF (p_priority IS NOT NULL) THEN

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

Line 3661: IF (p_commit_mode = XNP_MESSAGE.C_IMMEDIATE) THEN

3657: message_properties.recipient_list := recipients ;
3658:
3659: END IF;
3660:
3661: IF (p_commit_mode = XNP_MESSAGE.C_IMMEDIATE) THEN
3662: my_enqueue_options.visibility := DBMS_AQ.IMMEDIATE ;
3663: ELSE
3664: my_enqueue_options.visibility := DBMS_AQ.ON_COMMIT ;
3665: END IF ;