问题标签 [activemq]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
2 回答
4625 浏览

jms - 我为 Jetty 使用哪些 JNDI 环境属性?

我正在运行 jetty-6.1.7,并且我有一个 ActiveMQConnectionFactory,我想通过 JNDITemplate 在我的 spring 配置中引用它。

我的 jetty.xml 配置是普通的:

而且我找不到在我的 spring 配置中放入 JNDI 模板的正确方法:

提前致谢!

0 投票
0 回答
744 浏览

python - 在osx上编译安装pyac​​tivemq

我很难在我的 osx leopard 上安装 pyactivemq(链接)。按照教程(葡萄牙语)编译它最终没问题,但是当我运行测试时,我只收到一条 crypt 消息:

网上没有太多关于在 osx 上使用 pyactivemq 的信息,但我能找到的是与 boost 编译时错误链接有关的东西。

我在跑:

  • Mac OS 10.5.8
  • MacPorts 1.8.2
  • 4 月 1.3.9 日
  • Xcode 3.1.4
  • Boost 1.41.0(为 python 2.5 安装)
  • 活动MQ-CPP 2.2.6
  • pyactivemq 0.1.0

如果有人对此有任何信息,那么知道我正在使用python 2.5从 macports 安装会很有帮助

0 投票
1 回答
3115 浏览

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

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

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

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

0 投票
1 回答
2485 浏览

wcf - Duplex or request-reply with Apache ActiveMQ WCF Binding 配置问题

我正在尝试将 Apache.NMS.WCF 绑定用于 WCF 应用程序并收到以下错误 -

合同需要 TwoWay(请求-答复或双工),但 Binding 'NmsBinding' 不支持它或未正确配置以支持它。

我的 system.service 模型如下所示 -

有没有办法将 Apache NMS 配置为双工或者它只是不支持它?

0 投票
3 回答
1627 浏览

activemq - 仅当从属在故障转移中变为活动状态时,如何在从属 ActiveMQ 上启动骆驼路由?

在嵌入式 Camel 路由中,我有一个远程 JMS 队列的持久消费者。是否可以通过主从配置进行这种路由?现在看来,Camel 路由在从 ActiveMQ 启动时已经启动和激活,而不是在实际故障转移发生时。

现在它会导致从属实例接收发送给主实例的相同消息,这会导致重复消息在故障转移时到达队列。

我正在使用 ActiveMQ 5.3 和 Apache Camel 2.1。

0 投票
4 回答
3204 浏览

c# - ActiveMq NMS 大约 30 秒后断开连接

'正在尝试使用 ActiveMq 进行简单的发布/订阅。我可以让它一切正常,但订阅者在大约 30 秒后断开连接。我一直在寻找可以更改的超时类型值,但似乎没有任何效果。这是订户:

我试过这个:

但这似乎并没有改变什么。

要解决问题,只需运行程序并等待大约 30 秒。您可以在 ActiveMQ 控制台中看到连接消失(默认为http://localhost:8161/admin/connections.jsp )

有任何想法吗?

0 投票
3 回答
9923 浏览

java - 将 Log4J JMSAppender 与 ActiveMQ 一起使用

我正在尝试使用 log4J JMSAppender 生成从 Log4J 通过 JMS 传送日志的概念证明。我已经尝试过 ActiveMQ 及其随附的示例。我把这个例子拆开,使它更通用并与多个平台兼容。

看起来我已经全部完成了,因为我可以看到与 ActiveMQ 的连接正在发生,但是当我获得 InitialContext 时代码挂起(-Dlog4j.debug设置 ActiveMQ 客户端类似乎调用 log4J 并加载属性,而这些属性反过来尝试为 JMSAppender 建立与 JMS 的连接)然后代码就挂起。我试图通过仅定义单个命名记录器的附加程序来隔离指向 JMS 的日志消息,并且org.apache.activemq包配置为使用ConsoleAppender

当指向配置了 JMS 队列的 Weblogic Server 时,相同的代码可以正常工作,但为了获得最大的兼容性,我需要尝试使其与 ActiveMQ 一起工作

我是否缺少一些“神奇”的配置来使 ActiveMQ 正常工作?

- 到目前为止工作中的一些示例片段来充实这个问题现在我手头有代码

log4j-jms.properties

这样做的目的是创建一个命名的 appender 'demo' 并在示例代码中抓取它来记录以确保 activemq 日志不会尝试将自身发送到 JMS

代码示例。它有点乱,因为我一直在用它来尝试使事情正常进行。就目前而言,当我将它指向 Weblogic 时它会起作用,并类似地切换 log4j 配置。此代码中的对象是确保我让主题的侦听器在单独的线程中运行

NewLog4jJMSAppenderExample.java

} }

设置 -Dlog4j.debug 时显示的日志记录

在这里它只是挂起并最终超时

0 投票
2 回答
2409 浏览

java - 多种语言的 ActiveMQ 发布者和订阅者 (C++ Java)

我想在两个进程中使用 ActiveMQ 作为 C++ 组件和 Java 组件之间通信的消息代理。例如。C++ 组件是发布者,Java 组件是订阅者(可能有多个订阅者)。我查看了 ActiveMQ 网站,它提到了 OpenWire 和 ActiveMQ-CPP 工具。但是,网站上的所有示例都对生产者和消费者使用相同的语言。

我的问题是:

1.ActiveMQ可以为不同语言的生产者/消费者工作吗?

2.在不同的过程中?如何?

0 投票
2 回答
5126 浏览

java - 如何让本地 ActiveMQ 代理“镜像”远程 ActiveMQ 代理上的队列?

我有一个本地 ActiveMQ 代理,它位于不可靠的 Internet 连接上,还有一个位于可靠数据中心的远程 ActiveMQ 代理。我已经整理了一个“存储和转发”设置,以便在 Internet 连接可用时将传出消息发送到远程代理。仅此一项就很好用,但是当消息出站时。

但是,现在我必须做相反的事情。这是场景:

  1. 一条新消息出现在远程ActiveMQ 代理中。消息被放入特定队列。
  2. 几分钟后,本地ActiveMQ 代理可以使用 Internet 连接。
  3. 然后,本地代理应该能够从远程代理中提取消息,并将其放入自己的本地队列中。
  4. 然后,本地消费者将能够看到该消息。

所以本质上,我需要本地代理成为远程队列的订阅消费者。我查看了 ActiveMQ 文档,但在 .xml 配置文件中找不到任何关于如何执行此操作的信息。

这是我应该寻找的吗?请参阅:“ActiveMQ:JMS 到 JMS 桥”

任何建议和提示将不胜感激。

0 投票
1 回答
5409 浏览

java - Spring DefaultMessageListenerContainer、ActiveMQ 和消息重新传递

如果我使用DefaultMessageListenerContainerSpring接收JMS 消息,即使我设置sessionAcknowledgeMode为 2,我也不会重新传递 JMS 消息。

在我的 JavaBean 中的情况下,消息在 JMS 提供程序 ( ActiveMQ ) 中未得到确认RuntimeException在队列中保持挂起状态。但它永远不会重新交付,我认为这是由于 Spring 从不调用的事实造成的,根据ActiveMQ 的文档,需要重新交付才能发生。onMessage()session.recover()

任何人都可以给我一个提示,我可以如何配置在 RuntimeExceptions 的情况下DefaultMessageListenerContainer调用?session.recover()

最好的问候,
马丁