DBA Data[Home] [Help]

APPS.XNP_WF_SYNC dependencies on XNP_SYNC_REGISTRATION

Line 51: -- column in xnp_sync_registration table to determine.

47: --------------------------------------------------------------------------
48: -- PROCEDURE: check_if_last()
49: -- PURPOSE: checks if the work flow invoking this procedure is
50: -- the last one to synchronize. Uses the parties_not_in_sync
51: -- column in xnp_sync_registration table to determine.
52: -- RETURNS YES or NO
53: --------------------------------------------------------------------------
54:
55: FUNCTION check_if_last (

Line 62: -- Description : Insert a row into the XNP_SYNC_REGISTRATION table

58: ,p_actid IN NUMBER
59: ) RETURN VARCHAR2;
60:
61: --------------------------------------------------------------------------
62: -- Description : Insert a row into the XNP_SYNC_REGISTRATION table
63: -- Access Type : PRIVATE
64: -- Overloaded : NO
65: --------------------------------------------------------------------------
66: --

Line 226: lv_sync_label xnp_sync_registration.sync_label%TYPE;

222: lv_order_id NUMBER;
223: lv_line_item_id NUMBER;
224: lv_wi_instance_id NUMBER;
225: lv_message_id NUMBER;
226: lv_sync_label xnp_sync_registration.sync_label%TYPE;
227:
228: e_SyncException EXCEPTION;
229:
230: BEGIN

Line 313: lv_status xnp_sync_registration.status%TYPE;

309: ,po_error_msg OUT NOCOPY VARCHAR2
310: )
311: IS
312:
313: lv_status xnp_sync_registration.status%TYPE;
314: lv_error_code NUMBER;
315: lv_error_msg VARCHAR2(300);
316:
317: -- Cursor to obtain a lock on the XNP_SYNC_REGISTRATION table

Line 317: -- Cursor to obtain a lock on the XNP_SYNC_REGISTRATION table

313: lv_status xnp_sync_registration.status%TYPE;
314: lv_error_code NUMBER;
315: lv_error_msg VARCHAR2(300);
316:
317: -- Cursor to obtain a lock on the XNP_SYNC_REGISTRATION table
318: --
319: CURSOR lv_sync_status_cur (cv_sync_label IN VARCHAR2) IS
320: SELECT status
321: FROM xnp_sync_registration

Line 321: FROM xnp_sync_registration

317: -- Cursor to obtain a lock on the XNP_SYNC_REGISTRATION table
318: --
319: CURSOR lv_sync_status_cur (cv_sync_label IN VARCHAR2) IS
320: SELECT status
321: FROM xnp_sync_registration
322: WHERE sync_label = cv_sync_label
323: FOR UPDATE OF status;
324:
325: BEGIN

Line 341: UPDATE xnp_sync_registration

337: END IF;
338:
339: -- Update the status of the Sync Registration
340: --
341: UPDATE xnp_sync_registration
342: SET status = pp_status
343: WHERE CURRENT OF lv_sync_status_cur;
344:
345: po_error_code := 0;

Line 368: lv_status xnp_sync_registration.status%TYPE;

364: ,po_error_msg OUT NOCOPY VARCHAR2
365: )
366: IS
367:
368: lv_status xnp_sync_registration.status%TYPE;
369: lv_error_code NUMBER;
370: lv_error_msg VARCHAR2(300);
371:
372: -- Cursor to obtain a lock on the XNP_SYNC_REGISTRATION table

Line 372: -- Cursor to obtain a lock on the XNP_SYNC_REGISTRATION table

368: lv_status xnp_sync_registration.status%TYPE;
369: lv_error_code NUMBER;
370: lv_error_msg VARCHAR2(300);
371:
372: -- Cursor to obtain a lock on the XNP_SYNC_REGISTRATION table
373: --
374: CURSOR lv_sync_status_cur (cv_sync_label IN VARCHAR2) IS
375: SELECT status
376: FROM xnp_sync_registration

Line 376: FROM xnp_sync_registration

372: -- Cursor to obtain a lock on the XNP_SYNC_REGISTRATION table
373: --
374: CURSOR lv_sync_status_cur (cv_sync_label IN VARCHAR2) IS
375: SELECT status
376: FROM xnp_sync_registration
377: WHERE sync_label = cv_sync_label
378: FOR UPDATE OF status;
379:
380: BEGIN

Line 396: UPDATE xnp_sync_registration

392: END IF;
393:
394: -- Update the status of the Sync Registration
395: --
396: UPDATE xnp_sync_registration
397: SET status = gv_SYNC_ACTIVE_STATUS
398: ,parties_not_in_sync = max_participants
399: WHERE CURRENT OF lv_sync_status_cur;
400:

Line 427: lv_sync_registration_id xnp_sync_registration.sync_registration_id%TYPE;

423: ,po_error_code OUT NOCOPY NUMBER
424: ,po_error_msg OUT NOCOPY VARCHAR2
425: )
426: IS
427: lv_sync_registration_id xnp_sync_registration.sync_registration_id%TYPE;
428: lv_sync_label xnp_sync_registration.sync_label%TYPE;
429: lv_range_count NUMBER := 0;
430: lv_error_code NUMBER := 0;
431: lv_error_msg VARCHAR2(300);

Line 428: lv_sync_label xnp_sync_registration.sync_label%TYPE;

424: ,po_error_msg OUT NOCOPY VARCHAR2
425: )
426: IS
427: lv_sync_registration_id xnp_sync_registration.sync_registration_id%TYPE;
428: lv_sync_label xnp_sync_registration.sync_label%TYPE;
429: lv_range_count NUMBER := 0;
430: lv_error_code NUMBER := 0;
431: lv_error_msg VARCHAR2(300);
432: e_SyncInsertException EXCEPTION;

Line 494: SELECT xnp_sync_registration_s.NEXTVAL

490: END LOOP;
491:
492: -- Get the next sequence number value
493:
494: SELECT xnp_sync_registration_s.NEXTVAL
495: INTO lv_sync_registration_id
496: FROM dual;
497:
498: -- Insert a Sync Registration

Line 552: l_sync_label xnp_sync_registration.sync_label%TYPE;

548: ,po_error_msg OUT NOCOPY VARCHAR2
549: ,po_result OUT NOCOPY VARCHAR2
550: )
551: IS
552: l_sync_label xnp_sync_registration.sync_label%TYPE;
553: l_status xnp_sync_registration.status%TYPE;
554: l_max_participants xnp_sync_registration.max_participants%TYPE;
555: l_parties_not_in_sync xnp_sync_registration.parties_not_in_sync%TYPE;
556: l_sync_reqd_flag VARCHAR2(100);

Line 553: l_status xnp_sync_registration.status%TYPE;

549: ,po_result OUT NOCOPY VARCHAR2
550: )
551: IS
552: l_sync_label xnp_sync_registration.sync_label%TYPE;
553: l_status xnp_sync_registration.status%TYPE;
554: l_max_participants xnp_sync_registration.max_participants%TYPE;
555: l_parties_not_in_sync xnp_sync_registration.parties_not_in_sync%TYPE;
556: l_sync_reqd_flag VARCHAR2(100);
557: l_order_id NUMBER;

Line 554: l_max_participants xnp_sync_registration.max_participants%TYPE;

550: )
551: IS
552: l_sync_label xnp_sync_registration.sync_label%TYPE;
553: l_status xnp_sync_registration.status%TYPE;
554: l_max_participants xnp_sync_registration.max_participants%TYPE;
555: l_parties_not_in_sync xnp_sync_registration.parties_not_in_sync%TYPE;
556: l_sync_reqd_flag VARCHAR2(100);
557: l_order_id NUMBER;
558: l_line_item_id NUMBER;

Line 555: l_parties_not_in_sync xnp_sync_registration.parties_not_in_sync%TYPE;

551: IS
552: l_sync_label xnp_sync_registration.sync_label%TYPE;
553: l_status xnp_sync_registration.status%TYPE;
554: l_max_participants xnp_sync_registration.max_participants%TYPE;
555: l_parties_not_in_sync xnp_sync_registration.parties_not_in_sync%TYPE;
556: l_sync_reqd_flag VARCHAR2(100);
557: l_order_id NUMBER;
558: l_line_item_id NUMBER;
559: l_wi_instance_id NUMBER;

Line 575: FROM xnp_sync_registration

571: -- to obtain a lock on the row
572:
573: CURSOR l_sync_reg_cur (cv_sync_label IN VARCHAR2) IS
574: SELECT status, max_participants
575: FROM xnp_sync_registration
576: WHERE sync_label = cv_sync_label
577: FOR UPDATE OF status, parties_not_in_sync ;
578:
579: BEGIN

Line 725: UPDATE xnp_sync_registration

721: l_status := gv_SYNC_ACTIVE_STATUS ;
722:
723: -- Reset Sync Registration Details
724:
725: UPDATE xnp_sync_registration
726: SET status = l_status
727: ,parties_not_in_sync = l_parties_not_in_sync
728: WHERE CURRENT OF l_sync_reg_cur;
729:

Line 754: -- Description : Insert a row into the XNP_SYNC_REGISTRATION table

750:
751: END publish_or_subscribe;
752:
753: --------------------------------------------------------------------------
754: -- Description : Insert a row into the XNP_SYNC_REGISTRATION table
755: -- Access Type : PRIVATE
756: -- Overloaded : NO
757: --------------------------------------------------------------------------
758: --

Line 775: INSERT INTO xnp_sync_registration (

771:
772: po_error_code := 0 ;
773: po_error_msg := NULL ;
774:
775: INSERT INTO xnp_sync_registration (
776: sync_registration_id
777: ,sync_label
778: ,order_id
779: ,status

Line 884: lv_sync_label xnp_sync_registration.sync_label%TYPE;

880: ,x_error_code OUT NOCOPY NUMBER
881: ,x_error_message OUT NOCOPY VARCHAR2
882: )
883: IS
884: lv_sync_label xnp_sync_registration.sync_label%TYPE;
885: lv_error_code NUMBER;
886: lv_error_msg VARCHAR2(300);
887:
888: e_Exception EXCEPTION;

Line 896: -- Update the XNP_SYNC_REGISTRATION status to ERROR

892: -- Get the SYNC_LABEL from the Event Message
893: --
894: lv_sync_label := p_msg_header.reference_id;
895:
896: -- Update the XNP_SYNC_REGISTRATION status to ERROR
897: --
898: Update_Sync_Status (pp_sync_label => lv_sync_label
899: ,pp_status => gv_SYNC_ERROR_STATUS
900: ,po_error_code => lv_error_code

Line 930: lv_sync_label xnp_sync_registration.sync_label%TYPE;

926: ,x_error_code OUT NOCOPY NUMBER
927: ,x_error_message OUT NOCOPY VARCHAR2)
928:
929: IS
930: lv_sync_label xnp_sync_registration.sync_label%TYPE;
931: lv_error_code NUMBER;
932: lv_error_msg VARCHAR2(300);
933:
934: e_Exception EXCEPTION;

Line 942: -- Update the XNP_SYNC_REGISTRATION status to ERROR

938: -- Get the SYNC_LABEL from the Event Message
939: --
940: lv_sync_label := p_msg_header.reference_id;
941:
942: -- Update the XNP_SYNC_REGISTRATION status to ERROR
943: --
944: Update_Sync_Status (pp_sync_label => lv_sync_label
945: ,pp_status => gv_SYNC_TIMEOUT
946: ,po_error_code => lv_error_code

Line 969: -- column in xnp_sync_registration table to determine.

965: --------------------------------------------------------------------------
966: -- PROCEDURE: is_last_sync()
967: -- PURPOSE: checks if the work flow invoking this procedure is
968: -- the last one to synchronize. Uses the parties_not_in_sync
969: -- column in xnp_sync_registration table to determine.
970: --------------------------------------------------------------------------
971: --------------------------------------------------------------------------
972:
973: PROCEDURE is_last_sync (

Line 1007: -- column in xnp_sync_registration table to determine.

1003: --------------------------------------------------------------------------
1004: -- PROCEDURE: check_if_last()
1005: -- PURPOSE: checks if the work flow invoking this procedure is
1006: -- the last one to synchronize. Uses the parties_not_in_sync
1007: -- column in xnp_sync_registration table to determine.
1008: -- RETURNS YES or NO
1009: --------------------------------------------------------------------------
1010: --------------------------------------------------------------------------
1011:

Line 1018: l_sync_label xnp_sync_registration.sync_label%TYPE;

1014: ,p_itemkey IN VARCHAR2
1015: ,p_actid IN NUMBER
1016: ) RETURN VARCHAR2
1017: IS
1018: l_sync_label xnp_sync_registration.sync_label%TYPE;
1019: l_parties_not_in_sync xnp_sync_registration.parties_not_in_sync%TYPE;
1020: l_max_participants xnp_sync_registration.max_participants%TYPE;
1021: l_order_id NUMBER;
1022: l_line_item_id NUMBER;

Line 1019: l_parties_not_in_sync xnp_sync_registration.parties_not_in_sync%TYPE;

1015: ,p_actid IN NUMBER
1016: ) RETURN VARCHAR2
1017: IS
1018: l_sync_label xnp_sync_registration.sync_label%TYPE;
1019: l_parties_not_in_sync xnp_sync_registration.parties_not_in_sync%TYPE;
1020: l_max_participants xnp_sync_registration.max_participants%TYPE;
1021: l_order_id NUMBER;
1022: l_line_item_id NUMBER;
1023: l_wi_instance_id NUMBER;

Line 1020: l_max_participants xnp_sync_registration.max_participants%TYPE;

1016: ) RETURN VARCHAR2
1017: IS
1018: l_sync_label xnp_sync_registration.sync_label%TYPE;
1019: l_parties_not_in_sync xnp_sync_registration.parties_not_in_sync%TYPE;
1020: l_max_participants xnp_sync_registration.max_participants%TYPE;
1021: l_order_id NUMBER;
1022: l_line_item_id NUMBER;
1023: l_wi_instance_id NUMBER;
1024: l_error_code NUMBER := 0;

Line 1039: FROM xnp_sync_registration

1035:
1036: CURSOR l_sync_reg_cur (cv_sync_label IN VARCHAR2) IS
1037: SELECT parties_not_in_sync,
1038: max_participants
1039: FROM xnp_sync_registration
1040: WHERE sync_label = cv_sync_label
1041: FOR UPDATE OF status,
1042: parties_not_in_sync;
1043: BEGIN

Line 1131: UPDATE xnp_sync_registration

1127: -- decrement the parties not in sync and update the registry
1128:
1129: l_parties_not_in_sync := l_parties_not_in_sync - 1;
1130:
1131: UPDATE xnp_sync_registration
1132: SET parties_not_in_sync = l_parties_not_in_sync
1133: WHERE CURRENT OF l_sync_reg_cur;
1134:
1135: