问题标签 [activemq-cpp]

我对活动 MQ 有点陌生，所以请多多包涵。

我正在尝试为我的一些 Java 和 CPP 应用程序利用 ActiveMQ 优先级备份功能。我在两个不同的服务器（本地和远程）上有两个代理，我希望我的应用程序具有以下行为。

1. 启动时始终连接到本地代理
2. 如果本地代理出现故障，请连接到远程
3. 在连接到远程时，如果本地恢复，我们然后重新连接到本地。

通过简单地将priorityBackup 添加到我的uri 选项，即故障转移：(tcp://local:61616,tcp://remote:61616)?randomize=false&priorityBackup=true

然而，在 CPP 方面，事情进展并不顺利。

以下在 CPP 应用程序上运行良好（具有基本的工作故障转移功能 - 也就是在本地出现故障时跳转到远程）

故障转移:(tcp://local:61616,tcp://remote:61616)?randomize=false

但是使用 priorityBackup 更新 uri 选项似乎完全破坏了故障转移功能（我的应用程序从不故障转移到远程代理，当他们的本地代理出现故障时，它们只是停留在某种无代理/边缘状态）故障转移：（tcp:// local:61616,tcp://remote:61616)?randomize=false&priorityBackup=true

我在这里有什么遗漏吗？我应该包括的额外 uri 选项？

更新：传输连接器信息

在我的 ubuntu 系统上，我编写了使用 activemq-cpp 3.6.0 和 mman.h 的代码，并且存在一个棘手的编译错误。

我写了一个非常简单的代码来验证这个问题：

这是编译错误消息：

如果我把“mman.h”放在“activemq/core/ActiveMQConnection.h”之后，就可以了。有人有同样的问题吗？

======2015/1/7 更新===================================== ======

我对这个问题有进一步的调查。在“位/mmap.h”中：

在“activemq/util/PrimitiveValueNode.h”中：

这里是冲突。所以“PrimitiveValueNode.h”必须包含在“mman.h”之前。

我认为这是说明为什么我们不应该在 C/C++ 代码中使用 #define 的典型场景。

问：我们想在不同的 Activemq 服务器上发布相同的消息。我们有什么办法吗？就像我们将发布一次一样，activemq 更改会将消息转发到另一个实例。

或者有什么方法可以通过 activemq 配置更改来做到这一点？

我正在用 C++ 编写一个 activemq 生产者，它正在将映射消息写入 .net 平台上的 activemq 队列。当我使用相同的消息时，我正在使用 来相应NMSXGroupID (of the ActiveMQMapMessage type)地路由消息。.net

当我写消息时，我想从 C++ 端设置相同的 id。

我正在使用 linux 端的 activemq-cpp 库创建一个侦听器。但是，windows 端的 java activemq 代理（服务器在 windows 上运行）会在 30 秒后断开连接。

错误信息是：

Transport Connection to : tcp://x.y.z.w failed: InactivityIOException: Channel was inactive for too <30000> long: tcp://x.y.z.w:12345

现在根据activemq文档，我尝试了以下操作：

1. 在创建连接时将连接 url 设置为以下： "tcp://x.y.z.w:61616?transport.useInactivityMonitor=false"/>

2. 在 activemq.xml 文件中，我设置了以下内容

   <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?wireFormat.maxInactivityDuration=0;maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600;transport.useInactivityMonitor=false"/>

但是，我仍然在30秒后断开连接。

我还缺少更多设置吗？

我有一个项目，我想在其中使用 activemq 生产者，因此我想在我的 CMakeLists.txt 中添加 activemq 库。

以前，我使用的是 MakeFile，我有以下代码：

我将库路径设置为变量并在链接过程中引用它们。

然而，对于 CMakeLists，它并不是那么简单。我的 CMakeLists 中有以下部分，但它不起作用：

我收到以下错误：

有谁知道如何在 CMakeLists 中使用 activemq？或者任何人都知道如何将 Makefile 命令转换为 CMakeLists 命令？实际上我认为问题在于我无法链接库，那里的绝对路径对于 CMake 风格来说看起来不太好，我的意思是，我几乎可以肯定这不是给出这样的路径的方式。

我有一个 CMS 生产者，它在 while 循环中发送消息。这是非常快速且不必要的。我想将此限制为每秒 1 条左右的消息。

我想知道CMS是否具有设置发送频率的功能或方法？

H，我希望为 activeMQ 生产者创建一个连接池，它可以用作任何队列的连接对象。我已经看到了 JMS::PooledConnection 的实现，可能我在 CMS 中也需要相同的实现（虽然在搜索时找不到任何东西）。是否有任何 API 可以提供相同的服务，或者是否有任何其他方式来获得上述功能。

我正在修改我的代码以支持 Windows 7 et 上的双栈环境。人。该代码使用 ActiveMQ-CPP (3.8.4)。我已将此设置为使用与 URI“tcp://[::1]:61616”上的代理的连接。我已经发现我需要用 APR_HAVE_IPV6 编译 APR。

现在的问题。当 APR 的 call_resolver() 方法使用主机名“[::1]”调用 getaddrinfo() 时，它返回“No such host is known”（代码 11001）。

我可以毫无问题地 ping [::1]。我尝试取消注释主机名中的 ::1 条目。我在我的界面上添加了 Internet 协议版本 6 复选框。

有什么我想念的想法吗？

Is there a way to add a list (vector) of messages as content to a message? I know there is no direct way of doing this, but what would be the workaround to achieve such behavior?

Regards Klaus