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

2024-04-16

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

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

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


好吧,自从提出这个问题以来已经过去了很多时间,但现在您有几个可用的活动:

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

其中 m_connection 是 IConnection 对象。

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

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

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如何使用 NMS 和 C# 识别 ActiveMQ 断开连接 的相关文章

  • 无法绑定到 Openshift 上的端口

    我在 openshift 上的应用程序中运行嵌入式 activemq 消息服务器 根据this 你只能绑定15000 35530 我尝试执行以下操作 但它引发了严重错误 可能是什么问题 我正在使用弹簧 这是我的一部分applicationC
  • 获取ActiveMQ中的队列名称列表

    我尝试过下面的代码来获取 ActiveMQ 中的队列列表 但它不起作用 我的 ActiveMQ 有 4 个队列 try ActiveMQConnection makeConnection URL start Set
  • ActiveMQ授权

    如果我想在Apache ActiveMQ上实现JAAS授权 是否必须使用activemq xml配置文件中的插件 这种方式确实不好 因为如果我想更改授权 我必须更改 activemq xml 文件并且restart服务器才能工作 有什么方法
  • activemq 用户无权创建:topic://ActiveMQ.Advisory.Connection

    我正在尝试在 activemq 中使用授权 但卡住了一段时间 这是我的java代码 当我删除授权插件时一切正常 我正在尝试创建一个名为 room2 的主题 Context jndiContext new InitialContext Con
  • ActiveMQ:通过JMX获取连接列表?

    如何获取ActiveMQ OpenWire 连接器的连接列表 JConsole 能够列出连接 但我看不到可以使用哪个 视图 来获取列表 连接的对象名称示例 org apache activemq BrokerName localhost T
  • 无法让 ActiveMQ 重新发送我的消息

    我有一个用 Java 编写的单线程 ActiveMQ 使用者 我想做的就是从队列中接收 一条消息 尝试将其发送到网络服务 如果成功则确认 它 如果 Web 服务调用失败 我希望消息保留在队列中 并在超时后重新发送 除了重新发送部分之外 它或
  • Apache Camel 到底是如何处理 JMSReplyTo 的?骆驼什么时候隐式使用目的地?

    使用 spring camel 我构建了一条从 JMS 主题进行消费的路由 预计为每个输入消息设置 JMSReplyTo 将消息分割成更小的块 将它们发送到 REST 处理器 然后聚合答案并应该生成发送到 JMSReplyTo 指向的目的地
  • 如何在Spring Boot中设置ActiveMQ端口?

    我在一台服务器上运行两个 Spring Boot 应用程序 两者都使用嵌入式 ActiveMQ JMS 我希望每个应用程序都有单独的 JMS 实例 我怎样才能为他们每个人设置端口 有没有类似的房产spring activemq port 当
  • SqlServer触发器可以推送到ActiveMQ吗

    谁能告诉我是否可以将数据从 SqlServer 触发器直接推送到 ActiveMQ 我查遍了 ActiveMQ 文档 但没有看到任何对它的引用 我们可以使用轮询数据库插入的服务 但触发器将是理想的解决方案 但触发器将是理想的解决方案 绝对不
  • 从 activemq 主题获取消息时,logstash 输入速度非常慢

    我已经在logstash中配置了JMS输入来订阅JMS主题消息并将消息推送到弹性搜索 input jms id gt my first jms yaml file gt D softwares logstash 6 4 0 config j
  • 如何在 JBoss 中配置 ActiveMQ JCA 连接器以使用 XA 连接?

    在 JBoss 5 1 0 上 我使用 ds xml 标准 jboss DS 配置了数据源 PostgreSQL 8 3 11 它使用 XADataSource PGXA数据源 http jdbc postgresql org develo
  • 如何设置activemq的队列最大长度

    我想知道是否可以在activemq上配置队列的最大长度 以便当队列的长度达到限制时 入队操作将失败或抛出异常 有人知道这个问题吗 任何帮助将不胜感激 多谢 看一下生产者流程控制http activemq apache org Produce
  • 如何根据消息头属性仅读取特定队列消息

    我在 activemq 队列中有一个消息列表 每条消息都有一个带有值的自定义标头属性 我应该如何才能仅访问那些自定义标头属性值 123 的消息 我正在使用类似下面的东西从队列中选择消息 如何选择具有 customHeaderProperty
  • 最大 MQTT 连接数

    我需要创建一个服务器场 可以处理 5 100 万个连接 5 00000 个主题 每个客户端一个 每秒处理 300k 消息 我尝试了解各种消息代理的功能 因此我目前使用两个 RHEL EC2 实例 r3 4xlarge 来获取大量可用资源 所
  • activemq-all“5.15.3”不适用于 Spring 5

    我正在将 Spring 从 4 x x 更新到 Spring 5 0 3 该项目使用ActiveMQ版本5 15 3 当我尝试使用最新版本的 Spring 部署应用程序时 出现以下错误 Caused by java lang NoSuchM
  • Activemq 关闭失败然后终止进程

    我正在实施复制的 leveldb activemq 设置 我有 3 个 activemq 实例在同一个盒子上运行 我正在配置文件中更改它们的 rmiPort amqpport 和 openwire 端口 配置看起来像这样
  • JMS 监听器 - 动态选择目的地

    我在部署在单独服务器上的 ActiveMQ 上有许多目的地 队列 我想从我的程序中动态收听这些目的地 目前我正在收听这些目的地 如下所示
  • MongoDB 架构设计 - 实时聊天

    我正在启动一个项目 我认为该项目特别适合 MongoDB 因为它提供的速度和可扩展性 我目前感兴趣的模块是与实时聊天有关的 如果我要在传统的 RDBMS 中执行此操作 我会将其分为 频道 一个频道有很多用户 用户 一个用户有一个频道但有多条
  • 主题消息可以在activemq中持久化吗?

    我对 JMS 和 ESB 非常陌生 我使用 activemq 作为 JMS 使用 mule 作为 ESB 当我将消息从一个队列转发到另一个队列时 jms 连接器参数 persistentDelivery 为 true 它会在 activem
  • 如何将 activemq-core.xsd url 与 jar 文件中找到的 activemq.xsd 关联?

    有人知道如何关联activemq core xsd网址与activemq xsd在 jar 文件 activemq core 5 2 0 jar 中找到 我在互联网上找到了一些解决方案 但没有成功 我收到此错误 Caused by org

随机推荐