APPS.ECX_INBOUND_TRIG dependencies on DBMS_AQ

Line 958: v_dequeueoptions dbms_aq.dequeue_options_t;

954: )
955: is
956: i_method_name varchar2(2000) := 'ecx_inbound_trig.getmsg_from_queue';
957: v_message system.ecxmsg;
958: v_dequeueoptions dbms_aq.dequeue_options_t;
959: v_messageproperties dbms_aq.message_properties_t;
960: c_nummessages CONSTANT INTEGER :=1;
961: e_qtimeout exception;
962: pragma exception_init(e_qtimeout,-25228);

Line 959: v_messageproperties dbms_aq.message_properties_t;

955: is
956: i_method_name varchar2(2000) := 'ecx_inbound_trig.getmsg_from_queue';
957: v_message system.ecxmsg;
958: v_dequeueoptions dbms_aq.dequeue_options_t;
959: v_messageproperties dbms_aq.message_properties_t;
960: c_nummessages CONSTANT INTEGER :=1;
961: e_qtimeout exception;
962: pragma exception_init(e_qtimeout,-25228);
963: l_retcode pls_integer := 0;

Line 975: v_dequeueoptions.navigation := dbms_aq.FIRST_MESSAGE;

971: if(l_statementEnabled) then
972: ecx_debug.log(l_statement,'i_queue_name',i_queue_name,i_method_name);
973: end if;
974:
975: v_dequeueoptions.navigation := dbms_aq.FIRST_MESSAGE;
976: v_dequeueoptions.dequeue_mode := dbms_aq.BROWSE;
977: for i in 1..c_nummessages
978: loop
979: v_dequeueoptions.wait:=dbms_aq.NO_WAIT;

Line 976: v_dequeueoptions.dequeue_mode := dbms_aq.BROWSE;

972: ecx_debug.log(l_statement,'i_queue_name',i_queue_name,i_method_name);
973: end if;
974:
975: v_dequeueoptions.navigation := dbms_aq.FIRST_MESSAGE;
976: v_dequeueoptions.dequeue_mode := dbms_aq.BROWSE;
977: for i in 1..c_nummessages
978: loop
979: v_dequeueoptions.wait:=dbms_aq.NO_WAIT;
980:

Line 979: v_dequeueoptions.wait:=dbms_aq.NO_WAIT;

975: v_dequeueoptions.navigation := dbms_aq.FIRST_MESSAGE;
976: v_dequeueoptions.dequeue_mode := dbms_aq.BROWSE;
977: for i in 1..c_nummessages
978: loop
979: v_dequeueoptions.wait:=dbms_aq.NO_WAIT;
980:
981: dbms_aq.dequeue
982: (
983: queue_name=>i_queue_name,

Line 981: dbms_aq.dequeue

977: for i in 1..c_nummessages
978: loop
979: v_dequeueoptions.wait:=dbms_aq.NO_WAIT;
980:
981: dbms_aq.dequeue
982: (
983: queue_name=>i_queue_name,
984: dequeue_options=>v_dequeueoptions,
985: message_properties=>v_messageproperties,

Line 1318: v_enqueueoptions dbms_aq.enqueue_options_t;

1314: )
1315: is
1316: i_method_name varchar2(2000) := 'ecx_inbound_trig.put_on_outbound';
1317: v_message system.ecxmsg;
1318: v_enqueueoptions dbms_aq.enqueue_options_t;
1319: v_messageproperties dbms_aq.message_properties_t;
1320: i_msgid raw(16);
1321: c_nummessages CONSTANT INTEGER :=1;
1322: e_qtimeout exception;

Line 1319: v_messageproperties dbms_aq.message_properties_t;

1315: is
1316: i_method_name varchar2(2000) := 'ecx_inbound_trig.put_on_outbound';
1317: v_message system.ecxmsg;
1318: v_enqueueoptions dbms_aq.enqueue_options_t;
1319: v_messageproperties dbms_aq.message_properties_t;
1320: i_msgid raw(16);
1321: c_nummessages CONSTANT INTEGER :=1;
1322: e_qtimeout exception;
1323:

Line 1496: dbms_aq.enqueue

1492: v_message.party_type := i_party_type;
1493:
1494: v_messageproperties.correlation := 'OXTA';
1495: -- Enqueue
1496: dbms_aq.enqueue
1497: (
1498: queue_name=>'ECX_OUTBOUND',
1499: enqueue_options=>v_enqueueoptions,
1500: message_properties=>v_messageproperties,