当前位置: 首页 > 知识库问答 >
问题:

ActiveMQ从代理接受来自Apache Camel的传入连接

曹沛
2023-03-14

我有以下配置:

  • 两个正在运行的Tomcat实例运行Apache Camel 2.20.2,它们使用竞争消费者概念来读取同一JMS消息队列的消息

碰巧,其中一个Camel实例连接到从属代理,即使从属代理未处于活动状态(即,从日志文件中可以看出,它没有锁定CAHADB)。

当这种情况发生时,驼峰实例上的路由被阻塞,我们得到一个ExchangeMedOutException,这会阻塞路由,消息正在排队。

WARN  EndpointMessageListener:213 - Execution of JMS message listener failed. Caused by: [org.apache.camel.RuntimeCamelException - org.apache.camel.ExchangeTimedOutException: The OUT message was not received within: 30000 millis. Exchange[ID-MXPBMES-01P-I02-1625784159041-1-16108]]

从属代理接受来自客户端应用程序的连接(在我们的例子中是Camel)正常吗?

共有1个答案

冀萧迟
2023-03-14

次要代理不应该接受连接,所以这听起来像是一个bug,尽管您没有使用最新的代理,所以在做任何事情之前,您应该更新到最新的版本,因为总是有bug修复在进行。

如果基础文件系统不提供可靠的锁定机制,可能会出现一些问题,导致主代理和备份代理都处于活动状态。

 类似资料:
  • 问题内容: 我已经在机架空间上启动了CentOS服务器并执行了‘d。然后。因此,只是准系统。 我可以通过ssh(22)远程访问其IP地址,所以DNS或其他任何问题(我认为…)都没有问题,但是当我尝试通过浏览器等通过端口80进行连接时,拒绝连接。 但是,从本地主机,我可以使用telnet(80),甚至可以使用lynx并毫无问题地得到服务。telnet从外部(我的房子,我的学校,当地的咖啡店等)在22

  • 我想使用ActiveMQ创建一个代理来连接到另一个蚊子代理。然后,我可以使用ActiveMQ接收来自蚊子代理的消息。 我现在要做的是: 将ActiveMQ与JBoss EAP 6.3集成。 在ActiveMQ中创建MQTT代理:http://activemq.apache.org/mqtt.html 但是,在我添加代理配置中的网络连接器之后.xml: 服务器启动后显示异常: "vm://local

  • 问题内容: 我有一个简单的HTTP Server站在Golang中: 在调用方不是localhost的地方断开连接的最佳方法是什么?目前,我正在考虑检查底层的连接信息,并确保IP地址为,但这在最终删除连接之前浪费了大量资源(并运行了大量Go代码)。理想情况下,我可以检测Golang服务器以基于IP地址丢弃初始TCP SYN数据包,而根本不创建TCP连接(或显示该端口正在侦听)。 前进的最干净的道路

  • IntelliJ中的什么功能作为服务器来接受传入连接? 当第一次运行Intellij2017.1.1时,我会得到一个对话框,要求允许传入网络连接。 您希望应用程序“Java”接受传入的网络连接吗? null 这个问题不是关于消息的来源。源码是Apple macOS应用程序级防火墙。您可以允许或阻止应用程序侦听传入的网络连接。允许这样做是一个安全风险。 IntelliJ要求被添加到允许监听传入消息的

  • 德比文件说 德比。博士。主机名=主机名 该属性监听主机的网络连接,即接受来自主机的连接。如果指定了0.0.0.0,则接受来自任何主机的连接。 现在,我有三台远程计算机,,,。 我的derby服务器正在hostA上运行 所以,我写了 然而,这是行不通的。还有别的办法吗? 编辑: 当我将属性设置为 然后和不能连接到服务器。他们低于例外 JAVAsql。SQLNonTransientConnection

  • 这是我的蓝图代码。 内部消息工作。 外部消息不工作。 我在docker中运行Red Hat AMQ 7和Fuse 7。内部消息队列在服务之间正常工作。 使用AMQ 6,当在activemq中设置时,我能够向61613上的嵌入式代理发送和接收STOMP消息。xml 现在,我正在使用AMQ 7.0的默认设置,它将接受程序设置为0.0.0.0:61616和61613,这两个接受STOMP协议。 但是相同