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:

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:
963: no_messages exception;

Line 1012: -- l_dequeue_options.navigation := dbms_aq.FIRST_MESSAGE;

1008:
1009: l_dequeue_options.consumer_name := l_agent_name;
1010: l_dequeue_options.wait := p_wait;
1011: l_dequeue_options.navigation := wf_event.navigation;
1012: -- l_dequeue_options.navigation := dbms_aq.FIRST_MESSAGE;
1013:
1014: begin
1015: dbms_aq.dequeue(queue_name => l_queue_name,
1016: dequeue_options => l_dequeue_options,

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

1011: l_dequeue_options.navigation := wf_event.navigation;
1012: -- l_dequeue_options.navigation := dbms_aq.FIRST_MESSAGE;
1013:
1014: begin
1015: dbms_aq.dequeue(queue_name => l_queue_name,
1016: dequeue_options => l_dequeue_options,
1017: message_properties => l_message_properties, -- out
1018: payload => l_jms_text_message, -- out
1019: msgid => l_msgid); -- out

Line 1021: wf_event.navigation := dbms_aq.next_message;

1017: message_properties => l_message_properties, -- out
1018: payload => l_jms_text_message, -- out
1019: msgid => l_msgid); -- out
1020:
1021: wf_event.navigation := dbms_aq.next_message;
1022: exception
1023: when no_messages then
1024: if (wf_log_pkg.level_event >= fnd_log.g_current_runtime_level) then
1025: wf_log_pkg.string(wf_log_pkg.level_event,

Line 1030: wf_event.navigation := dbms_aq.first_message;

1026: 'wf.plsql.WF_EVENT_OJMSTEXT_QH.dequeue.queue_empty',
1027: 'No more messages in dequeue.');
1028: end if;
1029:
1030: wf_event.navigation := dbms_aq.first_message;
1031: p_event := null;
1032:
1033: return;
1034: --Capture the snapshot too old error

Line 1039: if (wf_event.navigation = dbms_aq.FIRST_MESSAGE) then

1035: when snap_too_old then
1036: --Workaround for AQ when receiving ORA-01555 using NEXT_MESSAGE as
1037: --navigation. We will try to set to FIRST_MESSAGE and dequeue to
1038: --silently handle this exception.
1039: if (wf_event.navigation = dbms_aq.FIRST_MESSAGE) then
1040: raise;
1041: else
1042: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
1043: l_dequeue_options.navigation := wf_event.navigation;

Line 1042: wf_event.navigation := dbms_aq.FIRST_MESSAGE;

1038: --silently handle this exception.
1039: if (wf_event.navigation = dbms_aq.FIRST_MESSAGE) then
1040: raise;
1041: else
1042: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
1043: l_dequeue_options.navigation := wf_event.navigation;
1044: dbms_aq.dequeue(queue_name => l_queue_name,
1045: dequeue_options => l_dequeue_options,
1046: message_properties => l_message_properties, -- out

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

1040: raise;
1041: else
1042: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
1043: l_dequeue_options.navigation := wf_event.navigation;
1044: dbms_aq.dequeue(queue_name => l_queue_name,
1045: dequeue_options => l_dequeue_options,
1046: message_properties => l_message_properties, -- out
1047: payload => l_jms_text_message, -- out
1048: msgid => l_msgid); -- out

Line 1051: wf_event.navigation := dbms_aq.next_message;

1047: payload => l_jms_text_message, -- out
1048: msgid => l_msgid); -- out
1049:
1050: --Set the navigation now to the next message
1051: wf_event.navigation := dbms_aq.next_message;
1052: end if;
1053: when others then
1054: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
1055: raise;

Line 1054: wf_event.navigation := dbms_aq.FIRST_MESSAGE;

1050: --Set the navigation now to the next message
1051: wf_event.navigation := dbms_aq.next_message;
1052: end if;
1053: when others then
1054: wf_event.navigation := dbms_aq.FIRST_MESSAGE;
1055: raise;
1056: end;
1057:
1058: deserialize(l_jms_text_message, p_event);