Vous pouvez écrire une procédure stockée et retirer le message en PL/SQL et le convertir en texte XML et le renvoyer en tant que CLOB. Ensuite, vous pouvez appeler la procédure stockée à partir de Java avec JDBC. J'ai déjà utilisé une solution de contournement similaire lorsqu'il manquait une fonctionnalité à l'API AQ ordinaire.
Exemple :
create or replace procedure dequeue_lcr(
p_queue_name varchar2,
p_consumer varchar2,
p_wait_seconds number,
p_lcr out clob) as
deq_lcr anydata;
deq_xml xmltype;
msgid raw(16);
deqopt dbms_aq.dequeue_options_t;
mprop dbms_aq.message_properties_t;
no_messages exception;
pragma exception_init (no_messages, -25228);
begin
deqopt.consumer_name := p_consumer;
deqopt.wait := p_wait_seconds;
deqopt.navigation := dbms_aq.first_message;
deqopt.dequeue_mode := dbms_aq.remove;
begin
dbms_aq.dequeue(
queue_name => p_queue_name,
dequeue_options => deqopt,
message_properties => mprop,
payload => deq_lcr,
msgid => msgid);
deq_xml := dbms_streams.convert_lcr_to_xml(deq_lcr);
p_lcr := deq_xml.getclobval();
commit;
exception
when no_messages then
p_lcr := null;
end;
end;
Cela fonctionne lorsque je l'appelle depuis PL/SQL avec la file d'attente et le consommateur appropriés :
declare
v_clob clob;
begin
dequeue_lcr('aqtest.hcb_queue_any', 'LOCAL_AGENT', 5, v_clob);
if (v_clob is not null) then
dbms_output.put_line('Data: ' || v_clob);
else
dbms_output.put_line('No messages');
end if;
end;
Faites simplement l'appel depuis Java avec un CallableStatement avec un clob comme paramètre de sortie et vous devriez être prêt à partir !