如何在 WildFly 10 中 @Inject 一个 JMSContext？

Posted 2023-02-27

【中文标题】如何在 WildFly 10 中 @Inject 一个 JMSContext？

【英文标题】：How do I @Inject a JMSContext in WildFly 10?

【发布时间】：2016-01-07 04:53:43

【问题描述】：

Java EE 7 消息驱动 bean 的此代码按预期接收消息，但无法发送回复，因为 JMSContext 始终为空。什么可能导致注射失败？

我尝试了不同的方法来注入上下文，有和没有额外的@JMSConnectionFactory 注解：

@JMSConnectionFactory("java:comp/DefaultJMSConnectionFactory")

或

@JMSConnectionFactory("java:/ConnectionFactory")

后者是管理网页界面的 JNDI 屏幕中显示的值。

package com.example.wf10mdb;

import javax.annotation.Resource;
import javax.ejb.ActivationConfigProperty;
import javax.ejb.MessageDriven;
import javax.inject.Inject;
import javax.jms.JMSConnectionFactory;
import javax.jms.JMSContext;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;
import javax.jms.Topic;

@MessageDriven(activationConfig
        = 
            @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms.Topic"),
            @ActivationConfigProperty(propertyName = "destination", propertyValue = "java:app/jms/topic/ExampleTopic")
        )
public class ChatMessageBean implements MessageListener 

    @Override
    public void onMessage(Message message) 
        try 

            final TextMessage textMessage = (TextMessage) message;
            final String question = textMessage.getText();

            System.out.println(question);

            if (null != question) 
                switch (question) 
                    case "Hello World!":
                        respond("Hello, Test Case!");
                        break;
                    case "How are you?":
                        respond("I'm doing well.");
                        break;
                    case "Still spinning?":
                        respond("Once every day, as usual.");
                        break;
                
            
         catch (JMSException e) 
            throw new IllegalStateException(e);
        
    

    @Resource(mappedName = "java:/jms/topic/ExampleTopic")
    private Topic answerTopic;

    @Inject
    @JMSConnectionFactory("java:/ConnectionFactory")
    JMSContext context;

    public void respond(String txt) 
        if (context == null) 
            System.out.println("context is null");
            return;
        

        try 
            context.createProducer().send(answerTopic, txt);
         catch (Exception exc) 
            exc.printStackTrace(System.out);
        
    

【参考方案1】：

Wildfly 10 默认没有激活 JMS 组件。此配置只是“standalone-full.xml”文件的一部分。 如果您使用标准的“standalone.xml”运行 Wildfly，您应该切换到 Standalone-full.xml 配置。 Wildfly 正在使用 Apache ActiveMQ。

这是一个带有自定义测试队列的messagin-activemq配置示例：

    ....
         <profile>
        .....
        <subsystem xmlns="urn:jboss:domain:messaging-activemq:1.0">
                    <server name="default">
                        <security-setting name="#">
                            <role name="guest" send="true" consume="true" create-non-durable-queue="true" delete-non-durable-queue="true"/>
                        </security-setting>
                        <address-setting name="#" dead-letter-address="jms.queue.DLQ" expiry-address="jms.queue.ExpiryQueue" max-size-bytes="10485760" page-size-bytes="2097152" message-counter-history-day-limit="10"/>
                        <http-connector name="http-connector" socket-binding="http" endpoint="http-acceptor"/>
                        <http-connector name="http-connector-throughput" socket-binding="http" endpoint="http-acceptor-throughput">
                            <param name="batch-delay" value="50"/>
                        </http-connector>
                        <in-vm-connector name="in-vm" server-id="0"/>
                        <http-acceptor name="http-acceptor" http-listener="default"/>
                        <http-acceptor name="http-acceptor-throughput" http-listener="default">
                            <param name="batch-delay" value="50"/>
                            <param name="direct-deliver" value="false"/>
                        </http-acceptor>
                        <in-vm-acceptor name="in-vm" server-id="0"/>
                        <jms-queue name="ExpiryQueue" entries="java:/jms/queue/ExpiryQueue"/>
                        <jms-queue name="DLQ" entries="java:/jms/queue/DLQ"/>
                        <connection-factory name="InVmConnectionFactory" connectors="in-vm" entries="java:/ConnectionFactory"/>
                        <connection-factory name="RemoteConnectionFactory" connectors="http-connector" entries="java:jboss/exported/jms/RemoteConnectionFactory"/>
                        <pooled-connection-factory name="activemq-ra" transaction="xa" connectors="in-vm" entries="java:/JmsXA java:jboss/DefaultJMSConnectionFactory"/>

                      <jms-queue name="testQueue"  entries="jms/queue/test java:jboss/exported/jms/queue/test" />
                    <jms-topic name="testTopic" entries="jms/topic/test java:jboss/exported/jms/topic/test" />
                    </server>
                </subsystem>
        ....

【讨论】：

我想添加How to configure jms in jboss eap 7，因为它展示了如何在不使用人们可能不想使用的standalone-full.xml 的情况下做到这一点，而只是更新standalone.xml 以支持JMS

【参考方案2】：

你有两个选择：

当您的 bean 使用范围类型进行注释时，服务器会将应用程序识别为 bean 存档，并且不需要额外的配置。

CDI 使用名为 beans.xml 的可选部署描述符。存档必须仅在某些有限的情况下（显式 bean 存档）包含 beans.xml 部署描述符，例如当 POJO 类没有 CDI 注释时。

对于 Web 应用程序，beans.xml 部署描述符（如果存在）必须位于 WEB-INF 目录中：webapp/WEB-INF/beans.xml 对于 EJB 模块或 JAR 文件，beans.xml 部署描述符，如果存在，必须在 META-INF 目录中：resources/META-INF/beans.xml

此文件可以为空：what is the purpose of including empty beans.xml in CDI implemenations projects?

打包 CDI 应用程序： https://docs.oracle.com/javaee/7/tutorial/cdi-adv001.htm

【参考方案3】：

答案很简单：默认情况下，容器不会在消息驱动 bean 中注入依赖项。当我将@ApplicationScoped 注解添加到bean 类时，JMSContext 将被注入。

【讨论】：

这不是必需的。

我同意约翰的观点，还有其他事情正在发生。我一直将东西注入 MDB，没有任何额外的注释。