在Open Liberty中编写Apache Qpid for Azure服务总线激活规范的正确方法

Question

我的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消息生成器）。

问题是使用消息驱动bean接收消息。我尝试了以下配置：

@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"),
})

Answer 1

我从没让MDB工作过。

我在JMSConsumer上使用了一个普通的MessageListener，尽管Javadoc声明如下：

在Java EE web或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();
}
}