APPS.WF_CLONE dependencies on DBMS_AQ

Line 478: l_dequeue_options dbms_aq.dequeue_options_t;

474: l_deq integer; -- dequeue count
475: l_xcount integer; -- commit frequency
476:
477: --Message Properties
478: l_dequeue_options dbms_aq.dequeue_options_t;
479: l_message_properties dbms_aq.message_properties_t;
480: l_message_handle RAW(16) := NULL;
481: l_payload wf_event_t;
482: l_consumer varchar2(100);

Line 479: l_message_properties dbms_aq.message_properties_t;

475: l_xcount integer; -- commit frequency
476:
477: --Message Properties
478: l_dequeue_options dbms_aq.dequeue_options_t;
479: l_message_properties dbms_aq.message_properties_t;
480: l_message_handle RAW(16) := NULL;
481: l_payload wf_event_t;
482: l_consumer varchar2(100);
483: l_msgid RAW(16);

Line 498: l_dequeue_options.dequeue_mode := dbms_aq.REMOVE_NODATA;

494:
495: --Since we are not planning any processing of the
496: --payload data take in the remove_nodata mode
497: --This avoids overhead of payload reterival
498: l_dequeue_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
499: l_dequeue_options.wait := dbms_aq.NO_WAIT;
500:
501: l_dequeue_options.navigation := dbms_aq.FIRST_MESSAGE;
502:

Line 499: l_dequeue_options.wait := dbms_aq.NO_WAIT;

495: --Since we are not planning any processing of the
496: --payload data take in the remove_nodata mode
497: --This avoids overhead of payload reterival
498: l_dequeue_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
499: l_dequeue_options.wait := dbms_aq.NO_WAIT;
500:
501: l_dequeue_options.navigation := dbms_aq.FIRST_MESSAGE;
502:
503: select qtab.RECIPIENTS ,qtab.queue_table

Line 501: l_dequeue_options.navigation := dbms_aq.FIRST_MESSAGE;

497: --This avoids overhead of payload reterival
498: l_dequeue_options.dequeue_mode := dbms_aq.REMOVE_NODATA;
499: l_dequeue_options.wait := dbms_aq.NO_WAIT;
500:
501: l_dequeue_options.navigation := dbms_aq.FIRST_MESSAGE;
502:
503: select qtab.RECIPIENTS ,qtab.queue_table
504: into l_consumer , l_qTable
505: from dba_queue_tables qtab , dba_queues aq

Line 537: dbms_aq.dequeue

533: exit when wait_msg%NOTFOUND;
534: l_dequeue_options.correlation := null;
535: l_dequeue_options.msgid := l_msgid;
536: begin
537: dbms_aq.dequeue
538: (
539: queue_name => QDequeue.owner||'.'||QDequeue.Qname,
540: dequeue_options => l_dequeue_options,
541: message_properties => l_message_properties,

Line 557: dbms_aq.Dequeue(queue_name => QDequeue.owner||'.'||QDequeue.Qname,

553:
554: l_dequeue_options.msgid := null;
555: while (l_timeout = 0) loop
556: begin
557: dbms_aq.Dequeue(queue_name => QDequeue.owner||'.'||QDequeue.Qname,
558: dequeue_options => l_dequeue_options,
559: message_properties => l_message_properties,
560: payload => l_payload,
561: msgid => l_message_handle);

Line 569: dbms_aqadm.start_queue(

565: exception
566: when dequeue_disabled then
567: --Incase dequeue has been disabled on the queue
568: --Enable the same and re-try the operation.
569: dbms_aqadm.start_queue(
570: queue_name =>QDequeue.Qname,
571: enqueue =>FALSE,
572: dequeue =>TRUE);
573: dbms_aq.Dequeue(queue_name => QDequeue.Qname,

Line 573: dbms_aq.Dequeue(queue_name => QDequeue.Qname,

569: dbms_aqadm.start_queue(
570: queue_name =>QDequeue.Qname,
571: enqueue =>FALSE,
572: dequeue =>TRUE);
573: dbms_aq.Dequeue(queue_name => QDequeue.Qname,
574: dequeue_options => l_dequeue_options,
575: message_properties => l_message_properties,
576: payload => l_payload,
577: msgid => l_message_handle);

Line 593: l_dequeue_options.navigation := dbms_aq.NEXT_MESSAGE;

589: end if;
590: end;
591:
592: --Move to next message
593: l_dequeue_options.navigation := dbms_aq.NEXT_MESSAGE;
594:
595: --Commit if commit frequency
596: if l_xcount >= l_commit_level then
597: commit;