DBA Data[Home] [Help]

APPS.XLA_ACCOUNTING_PKG dependencies on DBMS_AQ

Line 1519: dbms_aqadm.stop_queue(queue_name => g_queue_name

1515: ,p_level => C_LEVEL_EVENT
1516: ,p_module => l_log_module);
1517: END IF;
1518:
1519: dbms_aqadm.stop_queue(queue_name => g_queue_name
1520: ,wait => TRUE); --5056507
1521: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue stopped = '||g_queue_name);
1522: dbms_aqadm.stop_queue(queue_name => g_comp_queue_name
1523: ,wait => TRUE); --5056507

Line 1522: dbms_aqadm.stop_queue(queue_name => g_comp_queue_name

1518:
1519: dbms_aqadm.stop_queue(queue_name => g_queue_name
1520: ,wait => TRUE); --5056507
1521: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue stopped = '||g_queue_name);
1522: dbms_aqadm.stop_queue(queue_name => g_comp_queue_name
1523: ,wait => TRUE); --5056507
1524: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue stopped = '||g_comp_queue_name);
1525: g_queue_started_flag := 'N';
1526:

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

1539: ,p_level => C_LEVEL_EVENT
1540: ,p_module => l_log_module);
1541: END IF;
1542:
1543: dbms_aqadm.drop_queue(queue_name => g_queue_name);
1544: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue dropped = '||g_queue_name);
1545: dbms_aqadm.drop_queue(queue_name => g_comp_queue_name);
1546: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue dropped = '||g_comp_queue_name);
1547: g_queue_created_flag := 'N';

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

1541: END IF;
1542:
1543: dbms_aqadm.drop_queue(queue_name => g_queue_name);
1544: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue dropped = '||g_queue_name);
1545: dbms_aqadm.drop_queue(queue_name => g_comp_queue_name);
1546: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue dropped = '||g_comp_queue_name);
1547: g_queue_created_flag := 'N';
1548:
1549: IF (C_LEVEL_EVENT >= g_log_level) THEN

Line 3735: dbms_aqadm.create_queue

3731: ,p_level => C_LEVEL_EVENT
3732: ,p_module => l_log_module);
3733: END IF;
3734:
3735: dbms_aqadm.create_queue
3736: (queue_name => g_queue_name
3737: ,queue_table => g_queue_table_name); --C_QUEUE_TABLE);
3738: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue Created = '||g_queue_name);
3739:

Line 3740: dbms_aqadm.create_queue

3736: (queue_name => g_queue_name
3737: ,queue_table => g_queue_table_name); --C_QUEUE_TABLE);
3738: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue Created = '||g_queue_name);
3739:
3740: dbms_aqadm.create_queue
3741: (queue_name => g_comp_queue_name
3742: ,queue_table => g_queue_table_name); --C_QUEUE_TABLE);
3743: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue Created = '||g_comp_queue_name);
3744:

Line 3758: dbms_aqadm.start_queue

3754: ,p_level => C_LEVEL_EVENT
3755: ,p_module => l_log_module);
3756: END IF;
3757:
3758: dbms_aqadm.start_queue
3759: (queue_name => g_queue_name);
3760: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue Started = '||g_queue_name);
3761:
3762: dbms_aqadm.start_queue

Line 3762: dbms_aqadm.start_queue

3758: dbms_aqadm.start_queue
3759: (queue_name => g_queue_name);
3760: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue Started = '||g_queue_name);
3761:
3762: dbms_aqadm.start_queue
3763: (queue_name => g_comp_queue_name);
3764: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue Started = '||g_comp_queue_name);
3765:
3766: g_queue_started_flag := 'Y';

Line 4422: dbms_aqadm.stop_queue(queue_name => g_queue_name

4418: ,p_level => C_LEVEL_EVENT
4419: ,p_module => l_log_module);
4420: END IF;
4421:
4422: dbms_aqadm.stop_queue(queue_name => g_queue_name
4423: ,wait => TRUE); --5056507
4424: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue stopped = '||g_queue_name);
4425: dbms_aqadm.stop_queue(queue_name => g_comp_queue_name
4426: ,wait => TRUE); --5056507

Line 4425: dbms_aqadm.stop_queue(queue_name => g_comp_queue_name

4421:
4422: dbms_aqadm.stop_queue(queue_name => g_queue_name
4423: ,wait => TRUE); --5056507
4424: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue stopped = '||g_queue_name);
4425: dbms_aqadm.stop_queue(queue_name => g_comp_queue_name
4426: ,wait => TRUE); --5056507
4427: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue stopped = '||g_comp_queue_name);
4428: p_queue_started_flag := 'N';
4429:

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

4442: ,p_level => C_LEVEL_EVENT
4443: ,p_module => l_log_module);
4444: END IF;
4445:
4446: dbms_aqadm.drop_queue(queue_name => g_queue_name);
4447: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue dropped = '||g_queue_name);
4448: dbms_aqadm.drop_queue(queue_name => g_comp_queue_name);
4449: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue dropped = '||g_comp_queue_name);
4450: p_queue_created_flag := 'N';

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

4444: END IF;
4445:
4446: dbms_aqadm.drop_queue(queue_name => g_queue_name);
4447: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue dropped = '||g_queue_name);
4448: dbms_aqadm.drop_queue(queue_name => g_comp_queue_name);
4449: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Queue dropped = '||g_comp_queue_name);
4450: p_queue_created_flag := 'N';
4451:
4452: IF (C_LEVEL_EVENT >= g_log_level) THEN

Line 4573: l_enq_options dbms_aq.enqueue_options_t;

4569: l_entity_id xla_array_number_type; -- xla_number_array_type;
4570: l_entity_found BOOLEAN := FALSE;
4571: l_children_spawned BOOLEAN := FALSE;
4572: l_unit_count NUMBER := 0;
4573: l_enq_options dbms_aq.enqueue_options_t;
4574: l_msg_prop dbms_aq.message_properties_t;
4575: l_message xla_queue_msg_type; --SYSTEM.xla_queue_msg_type;
4576: l_msgid RAW(16);
4577:

Line 4574: l_msg_prop dbms_aq.message_properties_t;

4570: l_entity_found BOOLEAN := FALSE;
4571: l_children_spawned BOOLEAN := FALSE;
4572: l_unit_count NUMBER := 0;
4573: l_enq_options dbms_aq.enqueue_options_t;
4574: l_msg_prop dbms_aq.message_properties_t;
4575: l_message xla_queue_msg_type; --SYSTEM.xla_queue_msg_type;
4576: l_msgid RAW(16);
4577:
4578: l_event_class_code VARCHAR2(30);

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

4669:
4670: ----------------------------------------------------------------------------
4671: -- initiating queue/message related variables
4672: ----------------------------------------------------------------------------
4673: l_enq_options.visibility := dbms_aq.IMMEDIATE;
4674: l_enq_options.relative_msgid := NULL;
4675: l_enq_options.sequence_deviation := NULL;
4676:
4677: IF (p_processing_order = -1) THEN

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

4678: l_msg_prop.priority := p_max_processing_order+1;
4679: ELSE
4680: l_msg_prop.priority := p_processing_order;
4681: END IF;
4682: l_msg_prop.DELAY := dbms_aq.NO_DELAY;
4683: l_msg_prop.expiration := dbms_aq.NEVER;
4684: l_msg_prop.correlation := NULL;
4685: l_msg_prop.exception_queue := NULL;
4686: l_msg_prop.sender_id := NULL;

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

4679: ELSE
4680: l_msg_prop.priority := p_processing_order;
4681: END IF;
4682: l_msg_prop.DELAY := dbms_aq.NO_DELAY;
4683: l_msg_prop.expiration := dbms_aq.NEVER;
4684: l_msg_prop.correlation := NULL;
4685: l_msg_prop.exception_queue := NULL;
4686: l_msg_prop.sender_id := NULL;
4687:

Line 4846: dbms_aq.enqueue

4842:
4843: -------------------------------------------------------------------------
4844: -- enqueue the message in the queue
4845: -------------------------------------------------------------------------
4846: dbms_aq.enqueue
4847: (g_queue_name
4848: ,l_enq_options
4849: ,l_msg_prop
4850: ,l_message

Line 4906: l_conf_msg_prop dbms_aq.message_properties_t;

4902: PROCEDURE dequeue_completion_messages
4903: (p_msg_count INTEGER)
4904: IS
4905: l_msgid RAW(16);
4906: l_conf_msg_prop dbms_aq.message_properties_t;
4907: l_conf_message xla_queue_msg_type; -- SYSTEM.xla_queue_msg_type;
4908: l_deq_options dbms_aq.dequeue_options_t;
4909: l_msg_count INTEGER;
4910:

Line 4908: l_deq_options dbms_aq.dequeue_options_t;

4904: IS
4905: l_msgid RAW(16);
4906: l_conf_msg_prop dbms_aq.message_properties_t;
4907: l_conf_message xla_queue_msg_type; -- SYSTEM.xla_queue_msg_type;
4908: l_deq_options dbms_aq.dequeue_options_t;
4909: l_msg_count INTEGER;
4910:
4911: l_log_module VARCHAR2(240);
4912: BEGIN

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

4928: ,p_module => l_log_module);
4929: END IF;
4930:
4931: l_deq_options.consumer_name := NULL;
4932: l_deq_options.dequeue_mode := dbms_aq.REMOVE;
4933: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;
4934: l_deq_options.visibility := dbms_aq.IMMEDIATE;
4935: l_deq_options.wait := 60;
4936: l_deq_options.msgid := NULL;

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

4929: END IF;
4930:
4931: l_deq_options.consumer_name := NULL;
4932: l_deq_options.dequeue_mode := dbms_aq.REMOVE;
4933: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;
4934: l_deq_options.visibility := dbms_aq.IMMEDIATE;
4935: l_deq_options.wait := 60;
4936: l_deq_options.msgid := NULL;
4937: l_deq_options.correlation := NULL;

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

4930:
4931: l_deq_options.consumer_name := NULL;
4932: l_deq_options.dequeue_mode := dbms_aq.REMOVE;
4933: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;
4934: l_deq_options.visibility := dbms_aq.IMMEDIATE;
4935: l_deq_options.wait := 60;
4936: l_deq_options.msgid := NULL;
4937: l_deq_options.correlation := NULL;
4938:

Line 4962: dbms_aq.dequeue

4958: ,p_level => C_LEVEL_EVENT
4959: ,p_module => l_log_module);
4960: END IF;
4961:
4962: dbms_aq.dequeue
4963: (g_comp_queue_name
4964: ,l_deq_options
4965: ,l_conf_msg_prop
4966: ,l_conf_message

Line 5049: l_enq_options dbms_aq.enqueue_options_t;

5045: l_children_spawned BOOLEAN;
5046: l_msg_count INTEGER;
5047: l_msg_count2 INTEGER;
5048: l_total_msg_count INTEGER;
5049: l_enq_options dbms_aq.enqueue_options_t;
5050: l_msg_prop dbms_aq.message_properties_t;
5051: l_message xla_queue_msg_type; -- SYSTEM.xla_queue_msg_type;
5052: l_msgid RAW(16);
5053: l_max_processing_order INTEGER;

Line 5050: l_msg_prop dbms_aq.message_properties_t;

5046: l_msg_count INTEGER;
5047: l_msg_count2 INTEGER;
5048: l_total_msg_count INTEGER;
5049: l_enq_options dbms_aq.enqueue_options_t;
5050: l_msg_prop dbms_aq.message_properties_t;
5051: l_message xla_queue_msg_type; -- SYSTEM.xla_queue_msg_type;
5052: l_msgid RAW(16);
5053: l_max_processing_order INTEGER;
5054: l_num_level INTEGER;

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

5111: l_total_msg_count := 0;
5112: l_msg_count := 0;
5113: l_children_spawned := FALSE;
5114:
5115: l_enq_options.visibility := dbms_aq.IMMEDIATE;
5116: l_enq_options.relative_msgid := NULL;
5117: l_enq_options.sequence_deviation := NULL;
5118:
5119: l_msg_prop.priority := l_max_processing_order + 2;

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

5116: l_enq_options.relative_msgid := NULL;
5117: l_enq_options.sequence_deviation := NULL;
5118:
5119: l_msg_prop.priority := l_max_processing_order + 2;
5120: l_msg_prop.DELAY := dbms_aq.NO_DELAY;
5121: l_msg_prop.expiration := dbms_aq.NEVER;
5122: l_msg_prop.correlation := NULL;
5123: l_msg_prop.exception_queue := NULL;
5124: l_msg_prop.sender_id := NULL;

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

5117: l_enq_options.sequence_deviation := NULL;
5118:
5119: l_msg_prop.priority := l_max_processing_order + 2;
5120: l_msg_prop.DELAY := dbms_aq.NO_DELAY;
5121: l_msg_prop.expiration := dbms_aq.NEVER;
5122: l_msg_prop.correlation := NULL;
5123: l_msg_prop.exception_queue := NULL;
5124: l_msg_prop.sender_id := NULL;
5125:

Line 5228: dbms_aq.enqueue

5224: ,p_level => C_LEVEL_EVENT
5225: ,p_module => l_log_module);
5226: END IF;
5227:
5228: dbms_aq.enqueue
5229: (g_queue_name
5230: ,l_enq_options
5231: ,l_msg_prop
5232: ,l_message

Line 6122: l_deq_options dbms_aq.dequeue_options_t;

6118: PROCEDURE unit_processor IS
6119: TYPE t_lock_events_cur IS REF CURSOR;
6120: lock_events_cur t_lock_events_cur;
6121:
6122: l_deq_options dbms_aq.dequeue_options_t;
6123: l_enq_options dbms_aq.enqueue_options_t;
6124: l_msg_prop dbms_aq.message_properties_t;
6125: l_msgid RAW(16);
6126: --l_message xla_queue_msg_type; --SYSTEM.xla_queue_msg_type;

Line 6123: l_enq_options dbms_aq.enqueue_options_t;

6119: TYPE t_lock_events_cur IS REF CURSOR;
6120: lock_events_cur t_lock_events_cur;
6121:
6122: l_deq_options dbms_aq.dequeue_options_t;
6123: l_enq_options dbms_aq.enqueue_options_t;
6124: l_msg_prop dbms_aq.message_properties_t;
6125: l_msgid RAW(16);
6126: --l_message xla_queue_msg_type; --SYSTEM.xla_queue_msg_type;
6127: l_entity_count NUMBER := 0;

Line 6124: l_msg_prop dbms_aq.message_properties_t;

6120: lock_events_cur t_lock_events_cur;
6121:
6122: l_deq_options dbms_aq.dequeue_options_t;
6123: l_enq_options dbms_aq.enqueue_options_t;
6124: l_msg_prop dbms_aq.message_properties_t;
6125: l_msgid RAW(16);
6126: --l_message xla_queue_msg_type; --SYSTEM.xla_queue_msg_type;
6127: l_entity_count NUMBER := 0;
6128: l_event_count NUMBER := 0;

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

6213: ----------------------------------------------------------------------------
6214: -- Following initiates queue/message related variables
6215: ----------------------------------------------------------------------------
6216: l_deq_options.consumer_name := NULL;
6217: l_deq_options.dequeue_mode := dbms_aq.REMOVE;
6218: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;
6219: l_deq_options.visibility := dbms_aq.IMMEDIATE;
6220: l_deq_options.wait := 60;
6221: l_deq_options.msgid := NULL;

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

6214: -- Following initiates queue/message related variables
6215: ----------------------------------------------------------------------------
6216: l_deq_options.consumer_name := NULL;
6217: l_deq_options.dequeue_mode := dbms_aq.REMOVE;
6218: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;
6219: l_deq_options.visibility := dbms_aq.IMMEDIATE;
6220: l_deq_options.wait := 60;
6221: l_deq_options.msgid := NULL;
6222: l_deq_options.correlation := NULL;

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

6215: ----------------------------------------------------------------------------
6216: l_deq_options.consumer_name := NULL;
6217: l_deq_options.dequeue_mode := dbms_aq.REMOVE;
6218: l_deq_options.navigation := dbms_aq.FIRST_MESSAGE;
6219: l_deq_options.visibility := dbms_aq.IMMEDIATE;
6220: l_deq_options.wait := 60;
6221: l_deq_options.msgid := NULL;
6222: l_deq_options.correlation := NULL;
6223:

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

6220: l_deq_options.wait := 60;
6221: l_deq_options.msgid := NULL;
6222: l_deq_options.correlation := NULL;
6223:
6224: l_enq_options.visibility := dbms_aq.IMMEDIATE;
6225: l_enq_options.relative_msgid := NULL;
6226: l_enq_options.sequence_deviation := NULL;
6227:
6228: print_logfile(to_char(sysdate,'DD-MON-YYYY HH24:MI:SS')||' - Entering the loop to read document units from the queue ...');

Line 6296: dbms_aq.dequeue

6292:
6293: l_dequeue_flag := TRUE;
6294: WHILE (l_dequeue_flag) LOOP
6295: BEGIN
6296: dbms_aq.dequeue
6297: (g_queue_name
6298: ,l_deq_options
6299: ,l_msg_prop
6300: ,g_message

Line 6734: dbms_aq.enqueue

6730: ,p_module => l_log_module);
6731: END IF;
6732:
6733: g_message := xla_queue_msg_type(NULL);
6734: dbms_aq.enqueue
6735: (g_comp_queue_name
6736: ,l_enq_options
6737: ,l_msg_prop
6738: ,g_message

Line 6825: dbms_aq.enqueue

6821: END IF;
6822: EXCEPTION
6823: WHEN xla_exceptions_pkg.application_exception THEN
6824: g_message := xla_queue_msg_type(NULL);
6825: dbms_aq.enqueue
6826: (g_comp_queue_name
6827: ,l_enq_options
6828: ,l_msg_prop
6829: ,g_message

Line 6838: dbms_aq.enqueue

6834: THEN
6835: RAISE;
6836: END IF;
6837: g_message := xla_queue_msg_type(NULL);
6838: dbms_aq.enqueue
6839: (g_comp_queue_name
6840: ,l_enq_options
6841: ,l_msg_prop
6842: ,g_message