activemq - 如何使用 NMS 和 C# 识别 ActiveMQ 断开连接

Question

我有一个 C# 发布者和订阅者，它们使用 ActiveMQ 和 NMS 相互交谈。一切正常，除了我无法知道 ActiveMQ 何时出现故障。这对消费者来说尤其不利。他们停止获取数据，但除了数据停止显示这一事实之外，不会引发任何错误或事件。

有没有办法使用 NMS(特别是 Apache.NMS.IConnection 或 Apache.NMS.ISession 对象)

我从 Spring 下载了我正在使用的实现，但我没有使用任何特定的 spring 实现，我使用的所有内容都在 Apache.NMS 和 Apache.NMS.ActiveMQ 命名空间中。

Answer 1

好吧，自从提出这个问题以来已经很多了，但是现在您有几个可用的事件:

m_connection.ConnectionInterruptedListener += new ConnectionInterruptedListener(OnConnectionInterruptedListener);
m_connection.ConnectionResumedListener += new ConnectionResumedListener(OnConnectionResumedListener);
m_connection.ExceptionListener += new ExceptionListener(OnExceptionListener);

其中 m_connection 是一个 IConnection 对象。

通过这 3 个事件，您将能够找到您的经纪人何时关闭(以及其他有用的信息，例如何时恢复连接或他何时遇到异常)

注意:如果您处于故障转移模式，这些异常将被故障转移传输层吞并并与它们一起自动处理。因此，您将不会收到任何这些事件。