jakarta-ee - 检查ActiveMQ代理的状态

Question

我想创建一个Java类，其唯一目的是检查ActiveMQ代理的状态(或与ActiveMQ代理的连接，因为中断也可能被定义为客户端失去网络连接)。

因此，基本上每隔几秒钟就会有一个线程运行一次，以检查代理的状态，如果代理发生故障，我想做一些具体的任务，将支持组和类似的东西邮寄出去。

在线示例不够详细，无法解释如何实现上述目的。

有人已经做过这件事，还是可以建议实现这一目标的好方法？

谢谢，
内拉杰

Answer 1

发送测试消息给经纪人:

try {
    ActiveMQConnectionFactory factory = new ActiveMQConnectionFactory("tcp://localhost:61616");
    Connection conn = factory.createConnection(user, password);
    Session session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
    MessageProducer producer = session.createProducer("test");
    MessageConsumer consumer = session.createConsumer("test");
    consumer.setMessageListener(this); // class that implements MessageListener
    conn.start();
    TextMessage message = new ActiveMQTextMessage();
    message.setText("TestMessage");
    producer.send(message);
} catch (JMSException e) {
    // somethings very wrong
}

连接，发送消息，如果您收到消息:一切都很好。如果不....

我就是做这个的。此外，我还做其他一些事情:

收听多个咨询主题，以接收重要事件(例如Advisory.FULL)，这些重要事件指示出某些问题。

定期从统计信息插件获取代理统计信息，以监视消息的内存大小和消息存储。

配置一个死信队列，以便我知道消费者何时拒绝了一条消息。