DBA Data[Home] [Help]

APPS.XLA_ACCOUNTING_PKG dependencies on DBMS_AQ

Line 3499: dbms_aqadm.create_queue

3495: ,p_level => C_LEVEL_EVENT
3496: ,p_module => l_log_module);
3497: END IF;
3498:
3499: dbms_aqadm.create_queue
3500: (queue_name => g_queue_name
3501: ,queue_table => g_queue_table_name); --C_QUEUE_TABLE);
3502: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue Created = '||g_queue_name);
3503:

Line 3504: dbms_aqadm.create_queue

3500: (queue_name => g_queue_name
3501: ,queue_table => g_queue_table_name); --C_QUEUE_TABLE);
3502: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue Created = '||g_queue_name);
3503:
3504: dbms_aqadm.create_queue
3505: (queue_name => g_comp_queue_name
3506: ,queue_table => g_queue_table_name); --C_QUEUE_TABLE);
3507: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue Created = '||g_comp_queue_name);
3508:

Line 3522: dbms_aqadm.start_queue

3518: ,p_level => C_LEVEL_EVENT
3519: ,p_module => l_log_module);
3520: END IF;
3521:
3522: dbms_aqadm.start_queue
3523: (queue_name => g_queue_name);
3524: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue Started = '||g_queue_name);
3525:
3526: dbms_aqadm.start_queue

Line 3526: dbms_aqadm.start_queue

3522: dbms_aqadm.start_queue
3523: (queue_name => g_queue_name);
3524: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue Started = '||g_queue_name);
3525:
3526: dbms_aqadm.start_queue
3527: (queue_name => g_comp_queue_name);
3528: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue Started = '||g_comp_queue_name);
3529:
3530: l_queue_started_flag := 'Y';

Line 4152: dbms_aqadm.stop_queue(queue_name => g_queue_name

4148: ,p_level => C_LEVEL_EVENT
4149: ,p_module => l_log_module);
4150: END IF;
4151:
4152: dbms_aqadm.stop_queue(queue_name => g_queue_name
4153: ,wait => TRUE); --5056507
4154: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue stopped = '||g_queue_name);
4155: dbms_aqadm.stop_queue(queue_name => g_comp_queue_name
4156: ,wait => TRUE); --5056507

Line 4155: dbms_aqadm.stop_queue(queue_name => g_comp_queue_name

4151:
4152: dbms_aqadm.stop_queue(queue_name => g_queue_name
4153: ,wait => TRUE); --5056507
4154: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue stopped = '||g_queue_name);
4155: dbms_aqadm.stop_queue(queue_name => g_comp_queue_name
4156: ,wait => TRUE); --5056507
4157: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue stopped = '||g_comp_queue_name);
4158: p_queue_started_flag := 'N';
4159:

Line 4176: dbms_aqadm.drop_queue(queue_name => g_queue_name);

4172: ,p_level => C_LEVEL_EVENT
4173: ,p_module => l_log_module);
4174: END IF;
4175:
4176: dbms_aqadm.drop_queue(queue_name => g_queue_name);
4177: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue dropped = '||g_queue_name);
4178: dbms_aqadm.drop_queue(queue_name => g_comp_queue_name);
4179: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue dropped = '||g_comp_queue_name);
4180: p_queue_created_flag := 'N';

Line 4178: dbms_aqadm.drop_queue(queue_name => g_comp_queue_name);

4174: END IF;
4175:
4176: dbms_aqadm.drop_queue(queue_name => g_queue_name);
4177: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue dropped = '||g_queue_name);
4178: dbms_aqadm.drop_queue(queue_name => g_comp_queue_name);
4179: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue dropped = '||g_comp_queue_name);
4180: p_queue_created_flag := 'N';
4181:
4182: IF (C_LEVEL_EVENT >= g_log_level) THEN

Line 4303: l_enq_options dbms_aq.enqueue_options_t;

4299: l_entity_id xla_array_number_type; -- xla_number_array_type;
4300: l_entity_found BOOLEAN := FALSE;
4301: l_children_spawned BOOLEAN := FALSE;
4302: l_unit_count NUMBER := 0;
4303: l_enq_options dbms_aq.enqueue_options_t;
4304: l_msg_prop dbms_aq.message_properties_t;
4305: l_message xla_queue_msg_type; --SYSTEM.xla_queue_msg_type;
4306: l_msgid RAW(16);
4307:

Line 4304: l_msg_prop dbms_aq.message_properties_t;

4300: l_entity_found BOOLEAN := FALSE;
4301: l_children_spawned BOOLEAN := FALSE;
4302: l_unit_count NUMBER := 0;
4303: l_enq_options dbms_aq.enqueue_options_t;
4304: l_msg_prop dbms_aq.message_properties_t;
4305: l_message xla_queue_msg_type; --SYSTEM.xla_queue_msg_type;
4306: l_msgid RAW(16);
4307:
4308: l_event_class_code VARCHAR2(30);

Line 4403: l_enq_options.visibility := dbms_aq.IMMEDIATE;

4399:
4400: ----------------------------------------------------------------------------
4401: -- initiating queue/message related variables
4402: ----------------------------------------------------------------------------
4403: l_enq_options.visibility := dbms_aq.IMMEDIATE;
4404: l_enq_options.relative_msgid := NULL;
4405: l_enq_options.sequence_deviation := NULL;
4406:
4407: IF (p_processing_order = -1) THEN

Line 4412: l_msg_prop.DELAY := dbms_aq.NO_DELAY;

4408: l_msg_prop.priority := p_max_processing_order+1;
4409: ELSE
4410: l_msg_prop.priority := p_processing_order;
4411: END IF;
4412: l_msg_prop.DELAY := dbms_aq.NO_DELAY;
4413: l_msg_prop.expiration := dbms_aq.NEVER;
4414: l_msg_prop.correlation := NULL;
4415: l_msg_prop.exception_queue := NULL;
4416: l_msg_prop.sender_id := NULL;

Line 4413: l_msg_prop.expiration := dbms_aq.NEVER;

4409: ELSE
4410: l_msg_prop.priority := p_processing_order;
4411: END IF;
4412: l_msg_prop.DELAY := dbms_aq.NO_DELAY;
4413: l_msg_prop.expiration := dbms_aq.NEVER;
4414: l_msg_prop.correlation := NULL;
4415: l_msg_prop.exception_queue := NULL;
4416: l_msg_prop.sender_id := NULL;
4417:

Line 4575: dbms_aq.enqueue

4571:
4572: -------------------------------------------------------------------------
4573: -- enqueue the message in the queue
4574: -------------------------------------------------------------------------
4575: dbms_aq.enqueue
4576: (g_queue_name
4577: ,l_enq_options
4578: ,l_msg_prop
4579: ,l_message

Line 4635: l_conf_msg_prop dbms_aq.message_properties_t;

4631: PROCEDURE dequeue_completion_messages
4632: (p_msg_count INTEGER)
4633: IS
4634: l_msgid RAW(16);
4635: l_conf_msg_prop dbms_aq.message_properties_t;
4636: l_conf_message xla_queue_msg_type; -- SYSTEM.xla_queue_msg_type;
4637: l_deq_options dbms_aq.dequeue_options_t;
4638: l_msg_count INTEGER;
4639:

Line 4637: l_deq_options dbms_aq.dequeue_options_t;

4633: IS
4634: l_msgid RAW(16);
4635: l_conf_msg_prop dbms_aq.message_properties_t;
4636: l_conf_message xla_queue_msg_type; -- SYSTEM.xla_queue_msg_type;
4637: l_deq_options dbms_aq.dequeue_options_t;
4638: l_msg_count INTEGER;
4639:
4640: l_log_module VARCHAR2(240);
4641: BEGIN

Line 4661: l_deq_options.dequeue_mode := dbms_aq.REMOVE;

4657: ,p_module => l_log_module);
4658: END IF;
4659:
4660: l_deq_options.consumer_name := NULL;
4661: l_deq_options.dequeue_mode := dbms_aq.REMOVE;
4662: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;
4663: l_deq_options.visibility := dbms_aq.IMMEDIATE;
4664: l_deq_options.wait := 60;
4665: l_deq_options.msgid := NULL;

Line 4662: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;

4658: END IF;
4659:
4660: l_deq_options.consumer_name := NULL;
4661: l_deq_options.dequeue_mode := dbms_aq.REMOVE;
4662: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;
4663: l_deq_options.visibility := dbms_aq.IMMEDIATE;
4664: l_deq_options.wait := 60;
4665: l_deq_options.msgid := NULL;
4666: l_deq_options.correlation := NULL;

Line 4663: l_deq_options.visibility := dbms_aq.IMMEDIATE;

4659:
4660: l_deq_options.consumer_name := NULL;
4661: l_deq_options.dequeue_mode := dbms_aq.REMOVE;
4662: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;
4663: l_deq_options.visibility := dbms_aq.IMMEDIATE;
4664: l_deq_options.wait := 60;
4665: l_deq_options.msgid := NULL;
4666: l_deq_options.correlation := NULL;
4667:

Line 4691: dbms_aq.dequeue

4687: ,p_level => C_LEVEL_EVENT
4688: ,p_module => l_log_module);
4689: END IF;
4690:
4691: dbms_aq.dequeue
4692: (g_comp_queue_name
4693: ,l_deq_options
4694: ,l_conf_msg_prop
4695: ,l_conf_message

Line 4778: l_enq_options dbms_aq.enqueue_options_t;

4774: l_children_spawned BOOLEAN;
4775: l_msg_count INTEGER;
4776: l_msg_count2 INTEGER;
4777: l_total_msg_count INTEGER;
4778: l_enq_options dbms_aq.enqueue_options_t;
4779: l_msg_prop dbms_aq.message_properties_t;
4780: l_message xla_queue_msg_type; -- SYSTEM.xla_queue_msg_type;
4781: l_msgid RAW(16);
4782: l_max_processing_order INTEGER;

Line 4779: l_msg_prop dbms_aq.message_properties_t;

4775: l_msg_count INTEGER;
4776: l_msg_count2 INTEGER;
4777: l_total_msg_count INTEGER;
4778: l_enq_options dbms_aq.enqueue_options_t;
4779: l_msg_prop dbms_aq.message_properties_t;
4780: l_message xla_queue_msg_type; -- SYSTEM.xla_queue_msg_type;
4781: l_msgid RAW(16);
4782: l_max_processing_order INTEGER;
4783: l_num_level INTEGER;

Line 4844: l_enq_options.visibility := dbms_aq.IMMEDIATE;

4840: l_total_msg_count := 0;
4841: l_msg_count := 0;
4842: l_children_spawned := FALSE;
4843:
4844: l_enq_options.visibility := dbms_aq.IMMEDIATE;
4845: l_enq_options.relative_msgid := NULL;
4846: l_enq_options.sequence_deviation := NULL;
4847:
4848: l_msg_prop.priority := l_max_processing_order + 2;

Line 4849: l_msg_prop.DELAY := dbms_aq.NO_DELAY;

4845: l_enq_options.relative_msgid := NULL;
4846: l_enq_options.sequence_deviation := NULL;
4847:
4848: l_msg_prop.priority := l_max_processing_order + 2;
4849: l_msg_prop.DELAY := dbms_aq.NO_DELAY;
4850: l_msg_prop.expiration := dbms_aq.NEVER;
4851: l_msg_prop.correlation := NULL;
4852: l_msg_prop.exception_queue := NULL;
4853: l_msg_prop.sender_id := NULL;

Line 4850: l_msg_prop.expiration := dbms_aq.NEVER;

4846: l_enq_options.sequence_deviation := NULL;
4847:
4848: l_msg_prop.priority := l_max_processing_order + 2;
4849: l_msg_prop.DELAY := dbms_aq.NO_DELAY;
4850: l_msg_prop.expiration := dbms_aq.NEVER;
4851: l_msg_prop.correlation := NULL;
4852: l_msg_prop.exception_queue := NULL;
4853: l_msg_prop.sender_id := NULL;
4854:

Line 4957: dbms_aq.enqueue

4953: ,p_level => C_LEVEL_EVENT
4954: ,p_module => l_log_module);
4955: END IF;
4956:
4957: dbms_aq.enqueue
4958: (g_queue_name
4959: ,l_enq_options
4960: ,l_msg_prop
4961: ,l_message

Line 5744: l_deq_options dbms_aq.dequeue_options_t;

5740: PROCEDURE unit_processor IS
5741: TYPE t_lock_events_cur IS REF CURSOR;
5742: lock_events_cur t_lock_events_cur;
5743:
5744: l_deq_options dbms_aq.dequeue_options_t;
5745: l_enq_options dbms_aq.enqueue_options_t;
5746: l_msg_prop dbms_aq.message_properties_t;
5747: l_msgid RAW(16);
5748: --l_message xla_queue_msg_type; --SYSTEM.xla_queue_msg_type;

Line 5745: l_enq_options dbms_aq.enqueue_options_t;

5741: TYPE t_lock_events_cur IS REF CURSOR;
5742: lock_events_cur t_lock_events_cur;
5743:
5744: l_deq_options dbms_aq.dequeue_options_t;
5745: l_enq_options dbms_aq.enqueue_options_t;
5746: l_msg_prop dbms_aq.message_properties_t;
5747: l_msgid RAW(16);
5748: --l_message xla_queue_msg_type; --SYSTEM.xla_queue_msg_type;
5749: l_entity_count NUMBER := 0;

Line 5746: l_msg_prop dbms_aq.message_properties_t;

5742: lock_events_cur t_lock_events_cur;
5743:
5744: l_deq_options dbms_aq.dequeue_options_t;
5745: l_enq_options dbms_aq.enqueue_options_t;
5746: l_msg_prop dbms_aq.message_properties_t;
5747: l_msgid RAW(16);
5748: --l_message xla_queue_msg_type; --SYSTEM.xla_queue_msg_type;
5749: l_entity_count NUMBER := 0;
5750: l_event_count NUMBER := 0;

Line 5839: l_deq_options.dequeue_mode := dbms_aq.REMOVE;

5835: ----------------------------------------------------------------------------
5836: -- Following initiates queue/message related variables
5837: ----------------------------------------------------------------------------
5838: l_deq_options.consumer_name := NULL;
5839: l_deq_options.dequeue_mode := dbms_aq.REMOVE;
5840: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;
5841: l_deq_options.visibility := dbms_aq.IMMEDIATE;
5842: l_deq_options.wait := 60;
5843: l_deq_options.msgid := NULL;

Line 5840: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;

5836: -- Following initiates queue/message related variables
5837: ----------------------------------------------------------------------------
5838: l_deq_options.consumer_name := NULL;
5839: l_deq_options.dequeue_mode := dbms_aq.REMOVE;
5840: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;
5841: l_deq_options.visibility := dbms_aq.IMMEDIATE;
5842: l_deq_options.wait := 60;
5843: l_deq_options.msgid := NULL;
5844: l_deq_options.correlation := NULL;

Line 5841: l_deq_options.visibility := dbms_aq.IMMEDIATE;

5837: ----------------------------------------------------------------------------
5838: l_deq_options.consumer_name := NULL;
5839: l_deq_options.dequeue_mode := dbms_aq.REMOVE;
5840: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;
5841: l_deq_options.visibility := dbms_aq.IMMEDIATE;
5842: l_deq_options.wait := 60;
5843: l_deq_options.msgid := NULL;
5844: l_deq_options.correlation := NULL;
5845:

Line 5846: l_enq_options.visibility := dbms_aq.IMMEDIATE;

5842: l_deq_options.wait := 60;
5843: l_deq_options.msgid := NULL;
5844: l_deq_options.correlation := NULL;
5845:
5846: l_enq_options.visibility := dbms_aq.IMMEDIATE;
5847: l_enq_options.relative_msgid := NULL;
5848: l_enq_options.sequence_deviation := NULL;
5849:
5850: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Entering the loop to read document units from the queue ...');

Line 5918: dbms_aq.dequeue

5914:
5915: l_dequeue_flag := TRUE;
5916: WHILE (l_dequeue_flag) LOOP
5917: BEGIN
5918: dbms_aq.dequeue
5919: (g_queue_name
5920: ,l_deq_options
5921: ,l_msg_prop
5922: ,g_message

Line 6356: dbms_aq.enqueue

6352: ,p_module => l_log_module);
6353: END IF;
6354:
6355: g_message := xla_queue_msg_type(NULL);
6356: dbms_aq.enqueue
6357: (g_comp_queue_name
6358: ,l_enq_options
6359: ,l_msg_prop
6360: ,g_message

Line 6447: dbms_aq.enqueue

6443: END IF;
6444: EXCEPTION
6445: WHEN xla_exceptions_pkg.application_exception THEN
6446: g_message := xla_queue_msg_type(NULL);
6447: dbms_aq.enqueue
6448: (g_comp_queue_name
6449: ,l_enq_options
6450: ,l_msg_prop
6451: ,g_message

Line 6460: dbms_aq.enqueue

6456: THEN
6457: RAISE;
6458: END IF;
6459: g_message := xla_queue_msg_type(NULL);
6460: dbms_aq.enqueue
6461: (g_comp_queue_name
6462: ,l_enq_options
6463: ,l_msg_prop
6464: ,g_message