Oracle AQ java реализация enque / deque - PullRequest
0 голосов
/ 27 марта 2020

В течение последних нескольких дней я искал в течение rnet какой-либо работающий пример реализации Oracle Adavanced Queue для enque / deque сообщений, но безуспешно.

Я был пытаюсь следовать спецификации упомянутой oracle документации по этому вопросу, но это немного неясно для меня.

  • У него нет информации о доступных для использования зависимостях (maven / gradle). [Я узнал, что мне нужно использовать aqapi.jar ]. Любая специфицированная c версия, совместимая с драйвером jdb c, который я использую.

  • Я также использую пул соединений c3p0 для этого и ищу любую поддержку AQSession из коробки для c3p0, чтобы избежать соединения и обработки сеанса с точки зрения кода.

Примечание. Таблица очереди и очередь уже настроены на уровне базы данных. Я просто пытаюсь написать производителя / потребителя на делегирование сообщения. мы используем oracle 12 c и Java 11.

Любая информация будет очень признательна.

1 Ответ

1 голос
/ 28 марта 2020

Все, что вам нужно, это тонкий драйвер Oracle JDB C (ojdb c) для выполнения операций AQ, таких как постановка в очередь или удаление из очереди. См. Oracle JDB C Javado c для получения дополнительной информации об API. Также ознакомьтесь с другим вопросом о стековом потоке для некоторых примеров кода: Как ставить в очередь Oracle таблицу AQ при фиксации с Java и использовать с клиентом JMS

Обратите внимание, у вас есть два варианты: а) либо использовать API-интерфейсы AQ напрямую, либо б) использовать AQ-JMS, если вы хотите вместо этого использовать API-интерфейсы JMS.

aqapi.jar необходим только для целей администрирования, таких как «создание очереди», « начать очередь ", et c. В противном случае вам это не нужно.

...