5

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

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

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

4

1 回答 1

4

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

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

其中 m_connection 是一个 IConnection 对象。

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

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

于 2010-01-14T05:28:14.393 回答