Подключите OpenLiberty к RabbitMQ через JMS - PullRequest
Новая
       75

Подключите OpenLiberty к RabbitMQ через JMS

0 голосов
/ 27 апреля 2020

Я пишу Java EE 8 приложение, которое я хочу подключить к шине RabbitMQ. Приложение развернуто в OpenLiberty. Поскольку приложение использует Java EE 8, я хочу использовать JMS для подключения к RabbitMQ. Ранее я подключался к RabbitMQ через JMS в Tomcat в качестве подтверждения концепции, поэтому я знаю, что это должно быть возможно.

Согласно найденной документации и блогам, мне нужно Resource Adapter для подключения OpenLiberty практически ко всему, кроме внутреннего движка JMS. Я нашел адаптер ресурсов AMQP 1.0 и хотел попробовать.

Мой сервер. xml: 

<featureManager>
  <feature>beanValidation-2.0</feature>
  <feature>cdi-2.0</feature>
  <feature>jaxrs-2.1</feature>
  <feature>jsp-2.3</feature>
  <feature>servlet-4.0</feature>
  <feature>jms-2.0</feature>

  <feature>appSecurity-3.0</feature>
  <feature>socialLogin-1.0</feature>
</featureManager>

<!-- the resource-adapter-1.0.0.rar comes from the aforementioned GitHub project -->
<resourceAdapter id="amqp" location="${server.config.dir}/resource-adapter-1.0.0.rar">
  <classloader apiTypeVisibility="+third-party"/>
</resourceAdapter>

<jmsConnectionFactory jndiName="jms/JmsFactory">
  <!-- using .amqp as that is the ID for the resource adapter -->
  <properties.amqp ConnectionFactory=""
                   JndiParameters=""
                   DeleteTemporaryDestinations="true"
                   UserName=""
                   Password="" />
</jmsConnectionFactory>

Затем в коде моего приложения , У меня есть 

@Inject
@JMSConnectionFactory("jms/JmsFactory")
private JMSContext context;

Как только я вызываю context.createQueue("ExampleQueue") (или любой другой вызов метода), я получаю 

javax.naming.NameNotFoundException: Intermediate context does not exist: jms/JmsFactory

Я также попытался выполнить поиск вручную, вот так : 

final InitialContext context = new InitialContext();
final Context environment = (Context) context.lookup("java:comp/env");

final QueueConnectionFactory factory = (QueueConnectionFactory) environment.lookup("jms/JmsFactory");
final Queue queue = InitialContext.doLookup("jms/ExampleQueue");

Это не получается в environment.lookup с javax.naming.NameNotFoundException: java:comp/env/jms/JmsFactory.

Что я делаю не так или наблюдаю здесь?

1 Ответ

1 голос
/ 08 мая 2020

Существует несоответствие между тем, как Liberty ожидает, что будет определен адаптер ресурсов JMS, и тем, как этот адаптер ресурсов определяет себя. Liberty ожидает, что адаптер ресурсов JMS будет использовать классы JMS в ra. xml в качестве определения интерфейса, поэтому javax.jms.ConnectionFactory. Вместо этого RA использует org.jboss.resource.adapter.jms.JmsConnectionFactory. Во время выполнения это javax.jms.ConnectionFactory, но не в ra. xml.

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

<connectionFactory jndiName="jms/JmsFactory">
   <!-- using .amqp as that is the ID for the resource adapter -->
   <properties.amqp DeleteTemporaryDestinations="true"
       ConnectionFactory="factory1"
       JndiParameters="java.naming.factory.initial=org.apache.qpid.jms.jndi.JmsInitialContextFactory;connectionFactory.factory1=amqp://localhost:5672"              
       UserName=""
       Password="" />
</connectionFactory>

В Liberty есть ошибка для этой проблемы 12088 , но я бы предложил просто использовать элемент JCA connectionFactory для начала работы.

...