不能在java web servlet中直接调用ActiveMQConnection类

Question

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服务器，它加载了一个activemq-rar资源，我调用了一个servlet。我是按照这些指示去做的。

null

    /**
    * 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>

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

一定有办法解决这个问题。有人有想法吗？

Answer 1

您所指的超时与接收消息的消费者“响应”所需的时间无关。超时只是发送客户端等待代理确认它确实收到消息的时间。这发生在使用者收到消息之前。

如果您使用JMS实现请求/响应功能，那么您应该遵循正确的模式，使用相关ID或临时应答队列。

如果您使用的是ActiveMQ JCA资源适配器，那么您的客户机实际上从JNDI查找中获得的连接实现很可能会被容器的JCA实现包装。您不太可能简单地将其强制转换为ActiveMQ实现。此外，所有ActiveMQ客户机类都打包在JCA资源适配器存档中，并与应用程序隔离。如果将相同的类放在运行时环境的其他地方，可能会出现奇怪的类加载行为（例如，意外的ClassCastException)。Java EE应用程序服务器被设计为提供对Java EE API（例如JMS、JDBC、JNDI等）的访问。获得对底层实现的访问以执行不可移植的东西通常是困难的，也是不鼓励的。