Правильный способ написания спецификации активации в Open Liberty для Apache Qpid для Azure Service Bus - PullRequest
Новая
       69

Правильный способ написания спецификации активации в Open Liberty для Apache Qpid для Azure Service Bus

0 голосов
/ 06 мая 2019

Я успешно настроил JMS-клиент Apache Qpid (0.41.0) в Open Liberty для отправки сообщений в очередь служебной шины Azure.

Мой файл server.xml выглядит следующим образом: 

<jndiObjectFactory id="servicebusfactory" libraryRef="qpidlibsid"
   className="org.apache.qpid.jms.jndi.JNDIReferenceFactory" 
   objectClassName="org.apache.qpid.jms.JmsConnectionFactory">
</jndiObjectFactory>

<jndiReferenceEntry id="qpidconnectionfactory" 
  jndiName="jms/ServiceBus" 
  factoryRef="servicebusfactory">
  <properties remoteURI="amqps://xxx.servicebus.windows.net?amqp.idleTimeout=120000&amp;amqp.traceFrames=true&;jms.username=xxxx&amp;jms.password=xxx"/>
</jndiReferenceEntry>

<jndiObjectFactory id="queuefactory" libraryRef="qpidlibsid"
  className="org.apache.qpid.jms.jndi.JNDIReferenceFactory" 
  objectClassName="org.apache.qpid.jms.JmsQueue">
</jndiObjectFactory>

<jndiReferenceEntry id="myqueue" 
  jndiName="jms/myqueue" 
  factoryRef="queuefactory">
   <properties address="myqueue" />
</jndiReferenceEntry>

Используя приведенную выше конфигурацию сервера, я могу без проблем отправлять сообщения в очередь служебной шины (используя производителя сообщений JMS).

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

@MessageDriven(name = "processorMDB", activationConfig = {
    @ActivationConfigProperty(propertyName = "destinationLookup", propertyValue = "jms/myqueue"),
    @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Queue"),
    @ActivationConfigProperty(propertyName = "acknowledgeMode", propertyValue = "Auto-acknowledge"),
    @ActivationConfigProperty(propertyName = "connectionFactoryLookup", propertyValue = "jms/ServiceBus"),
})

Я получаю предупреждение при запуске Open Liberty:

[ПРЕДУПРЕЖДЕНИЕ] CNTR4016W: Конечная точка сообщения для bean-объекта, управляемого сообщениями CPUMDB, не может бытьактивирован, потому что пункт назначения jms / myqueue недоступен.Конечная точка сообщения не будет получать сообщения, пока адресат не станет доступным.

Мне нужна какая-то спецификация активации, которую я предполагаю, но я не могу заставить ее работать правильно.

Помощь или объяснениео том, как использовать спецификацию активации в Open Liberty, приветствуется!

Ответы [ 2 ]

0 голосов
/ 07 мая 2019

Я никогда не заставлял MDB работать.

Я использовал обычный MessageListener на JMSConsumer, и он прекрасно работает, даже если Javadoc утверждает следующее:

Этот метод не должениспользоваться в веб-приложениях Java EE или EJB.Это может привести к возникновению исключения JMSRuntimeException, хотя это не гарантируется.

Код: 

@Singleton
@Startup
public class CreditProcessorBeanListener {

@Resource(name = "jms/ServiceBus")
private ConnectionFactory connectionFactory;

@Resource(name = "jms/myqueue")
private Queue myqueue;
private JMSContext context;
private JMSConsumer consumer;


@PostConstruct
private void init() {
    initListener();
}

private void initListener() {
    context = connectionFactory.createContext();
    consumer = context.createConsumer(myqueue);
    consumer.setMessageListener(new MyListener());

}

@PreDestroy
private void destroy() {
    consumer.close();
    context.close();
}
}

Почему использование MessageListener в JMSConsumer не «разрешено» в JavaEE?Любые комментарии по этому поводу?

0 голосов
/ 06 мая 2019

Вы правы, что вам нужно настроить спецификацию активации JMS . Для этого вам нужно установить адаптер ресурсов JMS, для которого требуется функция jms-2.0, 

 <featureManager>
  <feature>jms-2.0</feature>
  <feature>mdb-3.2</feature>
  ... other features
 </featureManager>

 <resourceAdapter id="myJMSResourceAdapter" location="C:/adapters/jmsRA.rar"/>

 <jmsActivationSpec id="processorMDB">
   <properties.myJMSResourceAdapter .../>
 </jmsActivationSpec>

 <jmsQueue jndiName="jms/myqueue">
   <properties.myJMSResourceAdapter .../>  
 </jmsQueue>
...