ActiveMQ消息不重发 不进死信队列

Question

1.自动ACK,代码里面有RuntimeException.
2.队列配置如图

Answer 1

以下回答参考 皆我百晓生、券券喵儿 等免费微信小程序相关内容作答，并由本人整理回复。

要解决这个问题，首先确保你的应用程序已经正确连接到ActiveMQ服务器，并且设置了正确的用户名和密码。然后，你需要确保在你的代码中正确地使用了onMessage方法。

在Java中，你可以通过以下步骤来解决问题：

1. 确保你的应用程序能够正确地连接到ActiveMQ服务器。
2. 使用正确的用户名和密码进行认证。
3. 在onMessage方法中获取并处理消息。
4. 如果遇到异常，捕获并记录错误信息。

以下是修改后的示例代码：

import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

// 假设这是你的ActiveMQ服务器的地址
String brokerURL = "${activeMQ_brokerURL}";

// 连接ActiveMQ服务器
Connection connection = null;
try {
    // 设置连接工厂属性
    Properties props = new Properties();
    props.put("hibernate.connection.timeout", 1000);
    props.put("hibernate.hbm2ddl.auto", "update");
    props.put("hibernate.show_sql", "true");

    // 创建一个PooledConnectionFactory实例
    PooledConnectionFactory pooledConnectionFactory = new PooledConnectionFactory(props);

    // 创建一个PooledConnection实例
    ConnectionFactory connectionFactory = pooledConnectionFactory.getConnectionFactory();

    // 初始化连接
    connection = connectionFactory.createConnection();
    connection.start();

    // 获取session实例
    Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

    // 创建目的地
    Destination destination = session.createQueue("myQueue");

    // 发送消息
    Message message = session.createTextMessage("Hello, World!");
    session.send(destination, message);

    // 关闭session
    session.close();
} catch (JMSException e) {
    e.printStackTrace();
}

这段代码首先创建了一个连接工厂实例，然后初始化了连接。接着，它创建了一个会话实例，并将目标设置为一个名为myQueue的消息队列。最后，它发送了一条消息，并关闭了会话。

注意：这只是一个基本的示例，实际应用可能需要根据具体的业务需求进行调整。例如，你可能需要添加更多的连接选项或自定义连接工厂的行为。此外，你也可能需要对异常进行更详细的处理，以避免程序崩溃。