java - 无法在 java web servlet 中直接调用 ActiveMQConnection 类

问题描述

问题：

我正在尝试使用ActiveMQConnection对象设置超时以调用setSendTimeout我的 Java servlet 中的方法，但是当调用该代码时，我得到：

Warning:   RAR5038:Unexpected exception while creating resource for pool jms_amq_conn_pool. Exception : javax.resource.ResourceException: Could not create connection.
Warning:   RAR5117 : Failed to obtain/create connection from connection pool [ jms_amq_conn_pool ]. Reason : com.sun.appserv.connectors.internal.api.PoolingException: Could not create connection.

我怎样才能解决这个问题？

更详细的问题：

我有一个 Payara 服务器，它加载了我调用的 servlet 的 activemq-rar 资源。我按照这些说明进行操作。

这是一个列表，突出显示了该链接中的步骤：

获取 activemq rar 文件以部署到 Payara 服务器。
配置 ActiveMQ 连接器
创建 JMS 连接池
通过创建 JMS 资源来创建到 JMS 连接池的 JNDI 映射。

我有看起来像这样的 Java servlet 代码，当我希望它发送消息时可以正常工作：

    /**
    * Creates a connection using Payara resource then creates a producer/consumer then sends a message.
    */
    public void sendAMQMessage() {
        javax.jms.ConnectionFactory connectionFactory = InitialContext.doLookup("servlet_jms_amq_conn_factory");
        javax.jms.Connection connection = connectionFactory.createConnection();

        // creation is created, now set the client id and start it
        connection.setClientID("test_client_id");
        connection.start();

        javax.jms.Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

        javax.jms.TemporaryQueue queue = session.createTemporaryQueue();

        javax.jms.MessageConsumer consumer = session.createConsumer(queue);

        consumer.setMessageListener(this);

        javax.jms.Queue serviceQueue = session.createQueue("queue_name");

        javax.jms.MessageProducer producer = session.createProducer(serviceQueue);

        producer.send("data");
    
    }


    @Override
    public void onMessage(Message message) {
        // receives data back from the initial request.
    }

当前的 Web 应用程序pom.xml没有引用 ActiveMQ 库，因为上面的代码没有导入任何 ActiveMQ 类。但是我想对 Java servlet 发送的消息实现超时，以便如果接收应用程序在一定时间内没有响应，我可以处理它。

javax.jms.Connection没有超时设置方法。

ActiveMQConnectionJavaDoc确实有setSendTimeout(int sendTimeout)一个. 所以我在应用程序中包含了 ActiveMQ 依赖项pom.xml：

        <dependency>
            <groupId>org.apache.activemq</groupId>
            <artifactId>activemq-all</artifactId>
            <version>5.10.0</version>
            <type>jar</type>
        </dependency>

然后当我更新sendAMQMessage上面的方法以使用setSendTimeout(int sendTimeout)：

int milliseconds = 10000; // 10,000 ms = 10 seconds
((ActiveMQConnection)connection).setSendTimeout(milliseconds);

然后运行我得到这些警告和异常消息的代码：

Warning:   RAR5038:Unexpected exception while creating resource for pool jms_amq_conn_pool. Exception : javax.resource.ResourceException: Could not create connection.
Warning:   RAR5117 : Failed to obtain/create connection from connection pool [ jms_amq_conn_pool ]. Reason : com.sun.appserv.connectors.internal.api.PoolingException: Could not create connection.
Warning:   RAR5038:Unexpected exception while creating resource for pool jms_amq_conn_pool. Exception : javax.resource.ResourceException: Could not create connection.
Warning:   RAR5117 : Failed to obtain/create connection from connection pool [ jms_amq_conn_pool ]. Reason : com.sun.appserv.connectors.internal.api.PoolingException: Could not create connection.

javax.jms.JMSException: Error in allocating a connection. Cause: Could not create connection.
    at org.apache.activemq.ra.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:101)
    at org.apache.activemq.ra.ActiveMQConnectionFactory.createConnection(ActiveMQConnectionFactory.java:67)

我查看了这个链接，它说只需将 jar 复制到 Payara 服务器的domains/domain1/ilb/ext文件夹。所以我这样做了，activemq-all-5.10.0.jar然后当我运行上面的代码时，我得到了这个异常：

java.lang.ClassCastException: org.apache.activemq.command.ActiveMQQueue cannot be cast to javax.jms.Queue

必须有办法解决这个问题。有人有想法吗？

标签： javamavenweb-applicationsactivemqpayara

java - 无法在 java web servlet 中直接调用 ActiveMQConnection 类

问题描述

解决方案

推荐阅读