如何在JEE服务器（Wildfly）的JMS临时队列中创建监听器？

Question

我想在Wildfly 10中使用JMS 2.0创建临时JMS队列，并且注入连接工厂。

我使用@JMSConnectionFactory注入我的ConnectionFactory。这工作正常。

@Inject @JMSConnectionFactory("java:/jms/RemoteConnectionFactory") JMSContext jmsContext 

创建一个临时队列也能正常工作：

Destination jmsQueue = jmsContext.createTemporaryQueue(); 

创建出版商和出版信息工作好，以及：

JMSProducer producer = jmsContext.createProducer(); 
TextMessage msg = jmsContext.createTextMessage(Long.toString(new Date().getTime())); 
producer.send(jmsQueue, msg); 

但是，我怎么创建了一个监听器队列？由于临时队列未预定义，因此无法使用MDB。如果我尝试创建一个消费者，并分配一个消息监听器给它，我收到以下错误信息：

JMSConsumer consumer = jmsContext.createConsumer(jmsQueue); 
    consumer.setMessageListener(new MessageListener() { 
       ... 
       ... 
      }); 

错误跟踪：

Caused by: javax.jms.IllegalStateException: This method is not applicable inside the application server. See the J2EE spec, e.g. J2EE1.4 Section 6.6 
     at org.apache.activemq.artemis.ra.ActiveMQRASession.checkStrict(ActiveMQRASession.java:1452) 
     at org.apache.activemq.artemis.ra.ActiveMQRAMessageConsumer.setMessageListener(ActiveMQRAMessageConsumer.java:123) 
     at org.apache.activemq.artemis.jms.client.ActiveMQJMSConsumer.setMessageListener(ActiveMQJMSConsumer.java:59) 

这样看来，我不能明确地设定一个消息听众与JEE控制连接工厂。但考虑到它是一个临时队列，我无法创建一个MDB，因为在编译时不知道目的地。那么，我如何收听临时队列呢？

Answer 1

我只能通过使用JMS 1.0来解决这个问题。我有代码是这样的：

TopicConnectionFactory topicConnectionFactory; 
Topic topic; 
TopicConnection topicConnection; 

try { 
    InitialContext context = new InitialContext(); 
    topicConnectionFactory = (TopicConnectionFactory)jndi.lookup("jboss/DefaultJMSConnectionFactory"); 
    topic = (Topic)jndi.lookup("jms/myTopicName"); 

    topicConnection = topicConnectionFactory.createTopicConnection(); 

    TopicSession topicSession = topicConnection.createTopicSession(false, Session.AUTO_ACKNOWLEDGE); 

    TopicSubscriber topicSubscriber = topicSession.createSubscriber(projectTopic, null, false); 
    topicSubscriber.setMessageListener(listenerClass); 
    topicConnection.start(); 
} 
... 

其中listenerClass是实现javax.jms.MessageListener类。

这利用了在standalone-full.xml内的Wildfly中定义的预定义的JMS连接工厂，所以我不需要设置一个明确的。

作为一个警告 - 我运行此代码的最后一次是在Wildfly 8中，所以有些事情可能已经发生了一些变化。另外，我没有使用远程连接，因此，可能会有一些差异。