APPS.JTF_USR_HKS dependencies on DBMS_AQ

Line 1040: l_enqueue_options dbms_aq.enqueue_options_t;

1036: l_stage_obj SYSTEM.JTF_STAGING_MSG_OBJ :=
1037: SYSTEM.JTF_STAGING_MSG_OBJ( null,null,
1038: null,null,
1039: 0,null );
1040: l_enqueue_options dbms_aq.enqueue_options_t;
1041: l_message_properties dbms_aq.message_properties_t;
1042: l_Qname Varchar2(55) := 'JTF_STAGING_MSG_QUEUE';
1043: l_msg_id RAW(16);
1044: l_schema Varchar2(30);

Line 1041: l_message_properties dbms_aq.message_properties_t;

1037: SYSTEM.JTF_STAGING_MSG_OBJ( null,null,
1038: null,null,
1039: 0,null );
1040: l_enqueue_options dbms_aq.enqueue_options_t;
1041: l_message_properties dbms_aq.message_properties_t;
1042: l_Qname Varchar2(55) := 'JTF_STAGING_MSG_QUEUE';
1043: l_msg_id RAW(16);
1044: l_schema Varchar2(30);
1045:

Line 1058: dbms_aq.enqueue( queue_name => l_Qname ,

1054: l_stage_obj.action_code := p_action_code;
1055: l_stage_obj.correlation := p_correlation;
1056: l_stage_obj.bind_data_id := p_bind_data_id;
1057:
1058: dbms_aq.enqueue( queue_name => l_Qname ,
1059: enqueue_options => l_enqueue_options ,
1060: message_properties => l_message_properties ,
1061: payload => l_stage_obj ,
1062: msgid => l_msg_id );

Line 1089: l_enqueue_options dbms_aq.enqueue_options_t;

1085: l_excep_obj SYSTEM.JTF_EXCEP_MSG_OBJ :=
1086: SYSTEM.JTF_EXCEP_MSG_OBJ( null,null,
1087: null,null,
1088: 0,null,null );
1089: l_enqueue_options dbms_aq.enqueue_options_t;
1090: l_message_properties dbms_aq.message_properties_t;
1091: l_Qname Varchar2(55) := 'JTF_EXCEP_MSG_QUEUE';
1092: l_msg_id RAW(16);
1093: l_schema varchar2(30);

Line 1090: l_message_properties dbms_aq.message_properties_t;

1086: SYSTEM.JTF_EXCEP_MSG_OBJ( null,null,
1087: null,null,
1088: 0,null,null );
1089: l_enqueue_options dbms_aq.enqueue_options_t;
1090: l_message_properties dbms_aq.message_properties_t;
1091: l_Qname Varchar2(55) := 'JTF_EXCEP_MSG_QUEUE';
1092: l_msg_id RAW(16);
1093: l_schema varchar2(30);
1094: Begin

Line 1111: dbms_aq.enqueue( queue_name => l_Qname ,

1107: l_excep_obj.err_msg := p_err_msg;
1108:
1109: l_message_properties.correlation := p_correlation;
1110:
1111: dbms_aq.enqueue( queue_name => l_Qname ,
1112: enqueue_options => l_enqueue_options ,
1113: message_properties => l_message_properties ,
1114: payload => l_excep_obj ,
1115: msgid => l_msg_id );