DBA Data[Home] [Help]

APPS.JTF_FM_REQUEST_GRP dependencies on JTF_FM_REQUESTS_AQ

Line 171: Procedure to update JTF_FM_REQUESTS_AQ table.

167: JTF_FM_UTL_V.PRINT_MESSAGE('END' || l_full_name, JTF_FM_UTL_V.G_LEVEL_PROCEDURE ,l_full_name);
168:
169: END SWAP_QUEUES;
170: /**
171: Procedure to update JTF_FM_REQUESTS_AQ table.
172: */
173:
174: PROCEDURE UPDATE_RESUBMITTED
175: (

Line 721: Procedure to update JTF_FM_REQUESTS_AQ table.

717:
718: END INSERT_REQ_CONTENTS;
719:
720: /**
721: Procedure to update JTF_FM_REQUESTS_AQ table.
722: */
723:
724: PROCEDURE UPDATE_REQUESTS_AQ
725: (

Line 739: --UPDATE JTF_FM_REQUESTS_AQ with the new information

735:
736: BEGIN
737: JTF_FM_UTL_V.PRINT_MESSAGE('BEGIN' || l_full_name, JTF_FM_UTL_V.G_LEVEL_PROCEDURE ,l_full_name);
738:
739: --UPDATE JTF_FM_REQUESTS_AQ with the new information
740: UPDATE JTF_FM_REQUESTS_AQ
741: SET QUEUE_TYPE = p_queue_type ,
742: AQ_MSG_ID = p_new_msg_handle
743: WHERE REQUEST_ID = p_request_id

Line 740: UPDATE JTF_FM_REQUESTS_AQ

736: BEGIN
737: JTF_FM_UTL_V.PRINT_MESSAGE('BEGIN' || l_full_name, JTF_FM_UTL_V.G_LEVEL_PROCEDURE ,l_full_name);
738:
739: --UPDATE JTF_FM_REQUESTS_AQ with the new information
740: UPDATE JTF_FM_REQUESTS_AQ
741: SET QUEUE_TYPE = p_queue_type ,
742: AQ_MSG_ID = p_new_msg_handle
743: WHERE REQUEST_ID = p_request_id
744: AND AQ_MSG_ID = p_old_msg_handle;

Line 6187: -- if request_type = 'M' then get msg_ids from JTF_FM_REQUESTS_AQ for that request_id

6183: -- 10/24/02 sxkrishn Modifed for new schema changes
6184: -- Based on the request_id, get the type of request.
6185:
6186: -- If request_type = 'S''|| 'B' -proceed as ususal
6187: -- if request_type = 'M' then get msg_ids from JTF_FM_REQUESTS_AQ for that request_id
6188: -- And then dequeue them .
6189: ---------------------------------------------------------------
6190:
6191: PROCEDURE Cancel_Request(

Line 6246: FROM JTF_FM_REQUESTS_AQ

6242:
6243: --
6244: CURSOR CMASSMSG IS
6245: SELECT AQ_MSG_ID, QUEUE_TYPE
6246: FROM JTF_FM_REQUESTS_AQ
6247: WHERE REQUEST_ID = p_request_id;
6248:
6249: BEGIN
6250: JTF_FM_UTL_V.PRINT_MESSAGE('BEGIN '|| l_full_name,JTF_FM_UTL_V.G_LEVEL_PROCEDURE,l_full_name);

Line 6323: -- If it was a Mass req, check JTF_FM_REQUESTS_AQ as the mass req would have

6319: l_dequeue_options.msgid := l_message_handle;
6320: l_dequeue_options.dequeue_mode := DBMS_AQ.REMOVE;
6321:
6322: -- Based on the req type, get the Queue Name
6323: -- If it was a Mass req, check JTF_FM_REQUESTS_AQ as the mass req would have
6324: -- been split into several batch requests.
6325: -- Remove them from the queue
6326:
6327: IF l_request_type = 'M'

Line 6348: -- Mass request, so get records from JTF_FM_REQUESTS_AQ and dequeue them

6344: JTF_FM_UTL_V.HANDLE_ERROR('JTF_FM_API_ALREADY_CANCELED', to_char(p_request_id));
6345:
6346: ELSE
6347:
6348: -- Mass request, so get records from JTF_FM_REQUESTS_AQ and dequeue them
6349:
6350: --dbms_output.put_line('Mass req - so have to remove from AQ');
6351: OPEN CMASSMSG;
6352: IF(CMASSMSG%NOTFOUND)

Line 7396: FROM JTF_FM_REQUESTS_AQ

7392: --
7393:
7394: CURSOR CMASSMSG IS
7395: SELECT AQ_MSG_ID
7396: FROM JTF_FM_REQUESTS_AQ
7397: WHERE REQUEST_ID = p_request_id;
7398:
7399: --
7400: CURSOR CSTATUS( p_request_id NUMBER) IS

Line 7451: -- If it was a Mass req, check JTF_FM_REQUESTS_AQ as the mass req would have

7447: ELSIF l_request_status = 'IN_PROCESS'
7448: THEN
7449:
7450: -- Based on the req type, get the Queue Name
7451: -- If it was a Mass req, check JTF_FM_REQUESTS_AQ as the mass req would have
7452: -- been split into several batch requests.
7453: -- Remove them from the queue
7454: -- Mass request, so get records from JTF_FM_REQUESTS_AQ and dequeue them
7455: OPEN CMASSMSG;

Line 7454: -- Mass request, so get records from JTF_FM_REQUESTS_AQ and dequeue them

7450: -- Based on the req type, get the Queue Name
7451: -- If it was a Mass req, check JTF_FM_REQUESTS_AQ as the mass req would have
7452: -- been split into several batch requests.
7453: -- Remove them from the queue
7454: -- Mass request, so get records from JTF_FM_REQUESTS_AQ and dequeue them
7455: OPEN CMASSMSG;
7456: IF(CMASSMSG%NOTFOUND)
7457: THEN
7458: CLOSE CMASSMSG;

Line 7473: --UPDATE JTF_FM_REQUESTS_AQ with the new information

7469:
7470: SWAP_QUEUES(l_dequeue_name,l_message_handle,l_enqueue_name,l_message_handle_new);
7471:
7472: l_meaning := 'PAUSED';
7473: --UPDATE JTF_FM_REQUESTS_AQ with the new information
7474: UPDATE_REQUESTS_AQ(l_message_handle_new,p_request_id ,'BP', l_message_handle);
7475:
7476: END LOOP;
7477:

Line 7518: --UPDATE JTF_FM_REQUESTS_AQ with the new information

7514:
7515: SWAP_QUEUES(l_dequeue_name,l_message_handle,l_enqueue_name,l_message_handle_new);
7516:
7517: l_meaning := 'RESUMED';
7518: --UPDATE JTF_FM_REQUESTS_AQ with the new information
7519: UPDATE_REQUESTS_AQ(l_message_handle_new,p_request_id ,'M',l_message_handle);
7520: END IF; -- IF(CMASSMSG%NOTFOUND)
7521:
7522:

Line 7534: --UPDATE JTF_FM_REQUESTS_AQ with the new information

7530:
7531: SWAP_QUEUES(l_dequeue_name,l_message_handle,l_enqueue_name,l_message_handle_new);
7532:
7533: l_meaning := 'RESUMED';
7534: --UPDATE JTF_FM_REQUESTS_AQ with the new information
7535: UPDATE_REQUESTS_AQ(l_message_handle_new,p_request_id ,'B',l_message_handle);
7536:
7537: END LOOP;
7538: