问题标签 [activemq-cpp]

我做了一个测试，基于activemq-cpp库的示例解决方案。在测试中，我将 50,000 条消息发送到一个队列，在它们全部发送后，我INDIVIDUAL_ACKNOWLEDGE在会话和message->acknowledge()每条消费消息上使用它们。消费者是异步的。

发送消息前 java.exe 的内存（私有工作集）：209,320 KB。发送所有消息后：412,548 KB。使用所有消息后：434,637 KB。意思是，虽然队列大小为 0，但内存没有被释放。我错过了什么？谢谢。

我正在尝试第一次设置 Apache ActiveMQ

我发现我的服务器名称中有一个下划线，这阻止了 ActiveMQ 启动。它抛出这个异常：

java.net.URISyntaxException：索引 8 处的主机名中存在非法字符：ws://cms_delta.mycompany.com:61614？最大连接数=1000&wireFormat.maxFrameSize=104857600) ...

我在哪里可以在配置中设置主机名。此服务器有其他没有下划线的别名，或者我可以使用 IP 地址。服务器名称 cms_delta.mycompany.com 正在自动获取。

除了 brokerName，我在 activemq.xml 中没有看到任何明显的东西，但这并没有解决问题。

这是完整的日志：

有人可以告诉我如何安装 pyactivemq 吗？

我按照http://code.google.com/p/pyactivemq/wiki/Building的“Fedora Core”说明进行操作

I've worked with activemqcpp API before in a few projects, but I've always known what type the message are beforehand, so the dynamic casting to the corresponding message subclass was safe.

Now I'm building a wrapper for the MQ library and can't find a way to recognize from a base Message pointer (as returned by a receive) what message subclass does it match to cast it accordingly.

当 ActiveMQ CPP 尝试连接到我的 WildFly 实例时，我得到一个 decaf::util::NoSuchElementException。我正在使用最新的 ActiveMQ CMS 和 wildfly 8.0.Final。我正在使用 ActiveMQ CPP 附带的示例并指向我的 wildFly 实例。

brokerURI 是故障转移：(tcp://localhost:61613?wireFormat=stomp)

我的 Wildfly Standalone-full.xml 文件是

更新：似乎问题发生在连接启动时。即连接->开始（）

在输出产品中，我们偶尔需要计算队列中包含特定属性值的消息数量。直接的方法是使用带有选择器的队列浏览器。但：

1. 有没有办法在不浏览所有相关消息的情况下获取此统计信息？我们不需要数据，只需要计数。
2. 如果我们确实采用队列浏览器方法，它是否也会浏览某些消费者已消费但尚未确认的消息？

我一直在开发一个与 ActiveMQ-cpp（库版本 3.8.2）互连的线程数据池系统。系统管理一组设备，这些设备可以定期池化，轮询结果发送到代理中的队列。答案队列可以随时通过控制消息更改，因此生产者和目的地不断变化。只有一个订阅者接收所有控制命令，并且多个线程从它们自己的会话中创建生产者和消息。所有消息都是文本消息。

所有 activemq-cpp 元素都包裹在 RAII 元素中，但在密集使用后的某个时候，连接会收到消息，但是当我尝试发送响应时，库会抛出异常，显示“已达到线程本地存储限制”。之后它接收到更多消息（有时文本被破坏）但尝试发出新消息再次陷入线程存储异常，然后完全停止接收和发送。

有没有人发现这种问题？欢迎任何帮助。

更新：我已经编译并使用了新的3.8.3版本，仍然可以重现错误。测试是在 RHEL 5.7 和 Fedora 20 中完成的，它们都是 64 位架构。

我尝试从http://activemq.apache.org/cms/cms-api-overview.html运行一个示例，因此将代码粘贴main.cpp到我qt creator添加apr的activemq库中并成功编译，但之后没有任何反应。我的意思是控制台打印：

没有别的了。我通过简单地打印 couts 注意到

控制台没有打印第二个 cout 所以它一定是一个问题connection->start();你能帮我吗？

我在一个项目中使用 ActiveMQ-CPP 并想启动一个嵌入式代理。我找到了对“MockBrokerService”的引用，但找不到关于它的文档。我的发现说它用于测试。ActiveMQ-CPP 是否支持启动功能齐全的嵌入式代理，该代理可以与其他 ActiveMQ 实例交互以进行故障转移等？

考虑以下代码：

它无法解析 uri 值。我得到的错误是：

我在这里做错什么了吗？