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: (
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: (
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
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;
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(
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);
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'
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)
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
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;
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;
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:
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:
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: