Настройка JMS-провайдера с использованием OracleAQ - PullRequest
Новая
       41

Настройка JMS-провайдера с использованием OracleAQ

0 голосов
/ 30 июня 2019

У меня проблема с моим проектом.Я должен использовать OracleAQ в качестве поставщика JMS.Поскольку я совершенно новичок в JMS и не очень хорошо разбираюсь в Java, для меня это довольно сложно.

Я уже создал пользователя для постановки в очередь и снятия с очереди, а также таблицу для хранения сообщений и самой очереди.Я сделал это, используя следующий код: 

create role vis_aq_adm_role; 
grant connect, resource, aq_administrator_role, create any procedure to vis_aq_adm_role;

create role vis_aq_user_role;
grant create session, aq_user_role to vis_aq_user_role;

create user vis_aqadm identified by vis_aqadm; 
grant vis_aq_adm_role to vis_aqadm; 
grant execute on dbms_aq to vis_aqadm;

create user vis_aquser identified by vis_aquser;
grant connect, resource, create session to vis_aquser;
grant vis_aq_user_role to vis_aquser;
grant execute on dbms_aq to vis_aquser;

Создание таблицы и очереди: 

EXEC DBMS_AQADM.CREATE_QUEUE_TABLE(QUEUE_TABLE=>'VIS_JMS_MESSAGET', QUEUE_PAYLOAD_TYPE =>'SYS.AQ$_JMS_OBJECT_MESSAGE', MULTIPLE_CONSUMERS=>TRUE); 

EXEC DBMS_AQADM.CREATE_QUEUE(QUEUE_NAME => 'VIS_JMS_MESSAGEQ', QUEUE_TABLE => 'VIS_JMS_MESSAGET');

С этого момента я действительно не знаю, что делать.Насколько я понял всю вещь JMS / OracleAQ, я теперь вставляю сообщение в таблицу, используя какой-то код Java, а также удаляю сообщение из очереди, используя некоторый код Java.

Кто-нибудь знает хорошийучебник, который описывает следующие шаги?

Заранее спасибо:)

...