DBA Data[Home] [Help]

APPS.WF_EVENT_OJMSTEXT_QH dependencies on DBMS_AQ

Line 777: l_enqueue_options dbms_aq.enqueue_options_t;

773: l_to_protocol varchar2(30);
774: l_to_protocol_number number;
775:
776: l_delay number;
777: l_enqueue_options dbms_aq.enqueue_options_t;
778: l_message_properties dbms_aq.message_properties_t;
779: l_msgid raw(16);
780:
781: i number :=1;

Line 778: l_message_properties dbms_aq.message_properties_t;

774: l_to_protocol_number number;
775:
776: l_delay number;
777: l_enqueue_options dbms_aq.enqueue_options_t;
778: l_message_properties dbms_aq.message_properties_t;
779: l_msgid raw(16);
780:
781: i number :=1;
782: l_type varchar2(8);

Line 918: 'wf.plsql.WF_EVENT_OJMSTEXT_QH.enqueue.dbms_aq',

914: END IF;
915:
916: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
917: wf_log_pkg.string(wf_log_pkg.level_statement,
918: 'wf.plsql.WF_EVENT_OJMSTEXT_QH.enqueue.dbms_aq',
919: 'Calling dbms_aq.enqueue');
920: end if;
921:
922: dbms_aq.enqueue(queue_name => l_out_queue_name,

Line 919: 'Calling dbms_aq.enqueue');

915:
916: if (wf_log_pkg.level_statement >= fnd_log.g_current_runtime_level) then
917: wf_log_pkg.string(wf_log_pkg.level_statement,
918: 'wf.plsql.WF_EVENT_OJMSTEXT_QH.enqueue.dbms_aq',
919: 'Calling dbms_aq.enqueue');
920: end if;
921:
922: dbms_aq.enqueue(queue_name => l_out_queue_name,
923: enqueue_options => l_enqueue_options,

Line 922: dbms_aq.enqueue(queue_name => l_out_queue_name,

918: 'wf.plsql.WF_EVENT_OJMSTEXT_QH.enqueue.dbms_aq',
919: 'Calling dbms_aq.enqueue');
920: end if;
921:
922: dbms_aq.enqueue(queue_name => l_out_queue_name,
923: enqueue_options => l_enqueue_options,
924: message_properties => l_message_properties,
925: payload => l_jms_text_message,
926: msgid => l_msgid);

Line 934: 'Finished calling dbms_aq.enqueue');

930:
931: if (wf_log_pkg.level_procedure >= fnd_log.g_current_runtime_level) then
932: wf_log_pkg.string(wf_log_pkg.level_procedure,
933: 'wf.plsql.WF_EVENT_OJMSTEXT_QH.enqueue.End',
934: 'Finished calling dbms_aq.enqueue');
935: end if;
936:
937: exception
938: when others then

Line 958: l_dequeue_options dbms_aq.dequeue_options_t;

954: p_wait in binary_integer)
955: is
956: l_queue_name varchar2(80);
957: l_agent_name varchar2(30);
958: l_dequeue_options dbms_aq.dequeue_options_t;
959: l_message_properties dbms_aq.message_properties_t;
960: l_jms_text_message sys.aq$_jms_text_message;
961: l_msgid raw(16);
962: l_corrId_list varchar2(4000) := null;

Line 959: l_message_properties dbms_aq.message_properties_t;

955: is
956: l_queue_name varchar2(80);
957: l_agent_name varchar2(30);
958: l_dequeue_options dbms_aq.dequeue_options_t;
959: l_message_properties dbms_aq.message_properties_t;
960: l_jms_text_message sys.aq$_jms_text_message;
961: l_msgid raw(16);
962: l_corrId_list varchar2(4000) := null;
963:

Line 1046: dbms_aq.dequeue(queue_name => l_queue_name,

1042: l_dequeue_options.wait := p_wait;
1043: l_dequeue_options.navigation := wf_event.getQueueNavigation;
1044:
1045: begin
1046: dbms_aq.dequeue(queue_name => l_queue_name,
1047: dequeue_options => l_dequeue_options,
1048: message_properties => l_message_properties, -- out
1049: payload => l_jms_text_message, -- out
1050: msgid => l_msgid); -- out

Line 1070: dbms_aq.dequeue(queue_name => l_queue_name,

1066: when snap_too_old then
1067: -- reset navigation
1068: wf_event.resetNavigationParams;
1069: l_dequeue_options.navigation := wf_event.getQueueNavigation;
1070: dbms_aq.dequeue(queue_name => l_queue_name,
1071: dequeue_options => l_dequeue_options,
1072: message_properties => l_message_properties, -- out
1073: payload => l_jms_text_message, -- out
1074: msgid => l_msgid); -- out