APPS.ECX_INBOUND_TRIG dependencies on DBMS_AQ

Line 973: v_dequeueoptions dbms_aq.dequeue_options_t;

969: )
970: is
971: i_method_name varchar2(2000) := 'ecx_inbound_trig.getmsg_from_queue';
972: v_message system.ecxmsg;
973: v_dequeueoptions dbms_aq.dequeue_options_t;
974: v_messageproperties dbms_aq.message_properties_t;
975: c_nummessages CONSTANT INTEGER :=1;
976: e_qtimeout exception;
977: pragma exception_init(e_qtimeout,-25228);

Line 974: v_messageproperties dbms_aq.message_properties_t;

970: is
971: i_method_name varchar2(2000) := 'ecx_inbound_trig.getmsg_from_queue';
972: v_message system.ecxmsg;
973: v_dequeueoptions dbms_aq.dequeue_options_t;
974: v_messageproperties dbms_aq.message_properties_t;
975: c_nummessages CONSTANT INTEGER :=1;
976: e_qtimeout exception;
977: pragma exception_init(e_qtimeout,-25228);
978: l_retcode pls_integer := 0;

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

986: if(l_statementEnabled) then
987: ecx_debug.log(l_statement,'i_queue_name',i_queue_name,i_method_name);
988: end if;
989:
990: v_dequeueoptions.navigation := dbms_aq.FIRST_MESSAGE;
991: v_dequeueoptions.dequeue_mode := dbms_aq.BROWSE;
992: for i in 1..c_nummessages
993: loop
994: v_dequeueoptions.wait:=dbms_aq.NO_WAIT;

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

987: ecx_debug.log(l_statement,'i_queue_name',i_queue_name,i_method_name);
988: end if;
989:
990: v_dequeueoptions.navigation := dbms_aq.FIRST_MESSAGE;
991: v_dequeueoptions.dequeue_mode := dbms_aq.BROWSE;
992: for i in 1..c_nummessages
993: loop
994: v_dequeueoptions.wait:=dbms_aq.NO_WAIT;
995:

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

990: v_dequeueoptions.navigation := dbms_aq.FIRST_MESSAGE;
991: v_dequeueoptions.dequeue_mode := dbms_aq.BROWSE;
992: for i in 1..c_nummessages
993: loop
994: v_dequeueoptions.wait:=dbms_aq.NO_WAIT;
995:
996: dbms_aq.dequeue
997: (
998: queue_name=>i_queue_name,

Line 996: dbms_aq.dequeue

992: for i in 1..c_nummessages
993: loop
994: v_dequeueoptions.wait:=dbms_aq.NO_WAIT;
995:
996: dbms_aq.dequeue
997: (
998: queue_name=>i_queue_name,
999: dequeue_options=>v_dequeueoptions,
1000: message_properties=>v_messageproperties,

Line 1333: v_enqueueoptions dbms_aq.enqueue_options_t;

1329: )
1330: is
1331: i_method_name varchar2(2000) := 'ecx_inbound_trig.put_on_outbound';
1332: v_message system.ecxmsg;
1333: v_enqueueoptions dbms_aq.enqueue_options_t;
1334: v_messageproperties dbms_aq.message_properties_t;
1335: i_msgid raw(16);
1336: c_nummessages CONSTANT INTEGER :=1;
1337: e_qtimeout exception;

Line 1334: v_messageproperties dbms_aq.message_properties_t;

1330: is
1331: i_method_name varchar2(2000) := 'ecx_inbound_trig.put_on_outbound';
1332: v_message system.ecxmsg;
1333: v_enqueueoptions dbms_aq.enqueue_options_t;
1334: v_messageproperties dbms_aq.message_properties_t;
1335: i_msgid raw(16);
1336: c_nummessages CONSTANT INTEGER :=1;
1337: e_qtimeout exception;
1338:

Line 1511: dbms_aq.enqueue

1507: v_message.party_type := i_party_type;
1508:
1509: v_messageproperties.correlation := 'OXTA';
1510: -- Enqueue
1511: dbms_aq.enqueue
1512: (
1513: queue_name=>'ECX_OUTBOUND',
1514: enqueue_options=>v_enqueueoptions,
1515: message_properties=>v_messageproperties,