[Home] [Help]
1: PACKAGE BODY XDP_AQ_UTILITIES AS
2: /* $Header: XDPAQUTB.pls 120.1 2005/06/08 23:41:20 appldev $ */
3:
4: /** Private Functions **/
5:
683:
684:
685: EXCEPTION
686: WHEN OTHERS THEN
687: xdp_utilities.generic_error('XDP_AQ_UTILITIES.Add_OrdertoProcessorQ'
688: ,xdp_order.G_external_order_reference
689: ,sqlcode
690: ,sqlerrm);
691: END Add_OrderToProcessorQ;
2381: commit;
2382:
2383: exception
2384: when others then
2385: xdp_utilities.generic_error('XDP_AQ_UTILITIES.LogCommandAuditTrail',
2386: 'FA Instance: ' || FAInstanceID,
2387: sqlcode,
2388: sqlerrm);
2389: END LogCommandAuditTrail;
2485: commit;
2486:
2487: exception
2488: when others then
2489: xdp_utilities.generic_error('XDP_AQ_UTILITIES.LogCommandAuditTrail',
2490: 'FA Instance: ' || FAInstanceID,
2491: sqlcode,
2492: sqlerrm);
2493: END LogCommandAuditTrail;
2679:
2680: FOR i IN 1..G_DQ_COUNT
2681:
2682: LOOP
2683: XDP_AQ_UTILITIES.START_ORDERPROCESSOR_WORKFLOW( p_message_wait_timeout => g_msg_wait_timeout,
2684: p_correlation_id => null,
2685: x_message_key => l_message_key,
2686: x_queue_timed_out => l_time_out );
2687:
2721:
2722: FOR i IN 1..G_DQ_COUNT
2723:
2724: LOOP
2725: XDP_AQ_UTILITIES.START_FA_WORKFLOW( p_message_wait_timeout => g_msg_wait_timeout,
2726: p_correlation_id => null,
2727: x_message_key => l_message_key,
2728: x_queue_timed_out => l_time_out );
2729:
2763:
2764: FOR i IN 1..G_DQ_COUNT
2765:
2766: LOOP
2767: XDP_AQ_UTILITIES.RESUME_NEXT_WF( p_message_wait_timeout => g_msg_wait_timeout,
2768: p_correlation_id => null,
2769: x_message_key => l_message_key,
2770: x_queue_timed_out => l_time_out );
2771:
2807:
2808: FOR i IN 1..G_DQ_COUNT
2809:
2810: LOOP
2811: XDP_AQ_UTILITIES.START_WORKITEM_WORKFLOW( p_message_wait_timeout => g_msg_wait_timeout,
2812: p_correlation_id => null,
2813: x_message_key => l_message_key,
2814: x_queue_timed_out => l_time_out );
2815:
3870: 'XDPAQUTB'||to_char(g_logdate, 'YYYYMMDDHHMISS')||'.out',
3871: g_logdir);
3872: END IF;
3873:
3874: END XDP_AQ_UTILITIES;