问题标签 [qpid]

谁能分享一些关于如何开始使用 QPID 的链接？

我已经签出http://qpid.apache.org/我已经成功地启动了 Java QPID 代理，但我不知道从这里去哪里。

如果有人有一两个示例应用程序来使用代理并在 Java 或 C# 中相互发送消息，那就太好了。

如果没有，也许有人可以指出我正确的方向，并给我一些关于如何开始使用 QPID 的链接或文档。

谢谢

有没有人有在独立junit 测试中使用 Apache Qpid 的示例。

理想情况下，我希望能够动态创建一个队列，我可以在我的测试中放置/获取消息。所以我没有在我的测试中测试 QPid，我将为此使用集成测试，但是对于测试处理 msgs 的方法非常有用，因为它必须模拟大量服务。

我正在尝试构建Qpid。运行 CMake 时，这将打印到日志中：

它似乎失败了，因为它找不到应该生成的文件。但它没有，因为它无法找到 Ruby。

但它似乎至少部分找到了 Ruby，因为RUBY_*在 CMake 中设置了许多其他变量，如 RUBY_EXECUTABLE 和 RUBY_INCLUDE_DIR。

什么是 RUBY_LIBRARY，它应该设置为什么？Ruby 安装在 C:\Ruby192 中。

起初我认为 QPID 文档很棒，但现在我发现它令人困惑。我正在使用 QPID-0.6 的 C++ API 和qpid::messaging命名空间（我看到我可以使用qpid::client访问低级 AMQP ，但这不是我现在想要的）。

使用 AMQP，我会在发送消息之前声明一个类型的交换，声明一个队列和一个绑定。使用 QPID，我可以给发件人一个地址以发送到。是否有任何带有地址示例的文档，它们的作用相同吗？（创建各种交换、队列和创建绑定）。

值得注意的是，我在网上找到了一个地址语法，其中包括节点、链接、x-declare 和 x-binding 字段。然而，挖掘 0.6 代码并没有找到，而是看到了更简单的语法（带有名为 node-properties 和 x-properties 的字段），并且它的文档不是太简单，也缺少任何示例。

在examples/messaging/client.cpp中，这是我发现的最多的： #response-q; {create:always, type:queue, node-properties:{ x-properties:{auto-delete:true}}}

• 使用这种更简单的地址语法是否仍然可以设置各种类型的交换、队列和绑定？

• 或者迁移到 0.6 之后的东西会更可取？（如果它足够稳定，并且语法不那么讨厌）

• 或者我的方法是错误的，我不应该为与高级 API 的交换预先创建和绑定接收者队列？

谢谢你。

我正在尝试使用 QPid 作为 JMS 提供程序。Maven 被用作构建工具。我找不到包含 QPid 的 maven 存储库，因此我的构建失败。

问题

1. 有人知道包含 qpid 的 mvn 存储库吗？
2. 有解决办法吗？我已经下载了所有 JAR 文件并试图将它们放在 .m2/repository/org/apache/qpid/qpid-common/0.6 和 .m2/repository/org/apache/qpid/qpid-client/0.6 下

但是构建仍然失败。我相信我对 maven 的了解还不够多。那么，解决方案是什么？

大家好，我在这个例子中使用了 Apache Camel 和 Apache CXF：

http://camel.apache.org/better-jms-transport-for-cxf-webservice-using-apache-camel.data/cxfcamelexample.zip

我想使用 AMQP 而不是 JMS 但我不知道配置，如果有人可以提供帮助，我还需要更改 QPID 客户端的版本，这会很棒，在此先感谢。

最近我开始研究一个需要实现消息传递的项目，可行的选项是：Apache Qpid 或 RabbitMq，我的任务是这样的：

+A+ >>.[百万设备（生产者）--连接到--消息服务器（集群--Qpid或RabbitMQ）] {负载平衡）

接着

+B+ >>.[Messaging Server (Clustered -- Qpid or RabbitMQ) -- Connected to -- GateWay Server (Clustered) ]

接着

+C+ >>.[GateWay 服务器（集群）--连接到--Internet Explorer/浏览器（消费者）]

请参阅 +A+ >>-- 我通常需要使用消息传递来进行负载平衡，然后网关服务器将生成的数据中继给消费者（浏览器）

意味着通过使用一些负载平衡算法在 Broker 内部创建了几个队列。生产者（设备客户端）——将消息的数据发送到特定队列，基于循环或其他常见负载平衡算法传递到队列，可能它也需要 Ack 以保证传递，然后消费者从中挑选消息排队并进一步转发，所有非常标准的东西。

我学习了 AMQP 的基础知识，并执行了 Qpid 和 RabbitMQ 的基本示例，然后是我的问题：

• 有没有办法，或一些实验或任何东西可以提供一些东西来选择 RabbitMQ 或 Apache Qpid？

• 有没有人做过或多或少类似的要求？他/她可以提供任何意见吗？或者在实际实施算法、生产者和消费者实施之前的一些指示？

• 我的总体要求与负载平衡有关，因为我的项目期望数百万台设备连接到消息服务器——稍后消息数据将被中继，此时主要混淆选择 Apache Qpid 或 RabbitMQ，对我来说两者看起来都一样

Apache qpid-cpp 消息传递 api 是否支持像 ActiveMQ 中那样延迟传递消息？

我有以下情况：

我将 100 条消息推送到 2 个消费者共享的队列中。两个订阅者都以预获取模式和显式模式订阅队列。处理完每条消息后，每个订阅者都会接受该消息以将其从队列中删除。伪代码看起来像这样：

消息负载均衡正确，每条消息只处理一次，但我们发现它没有考虑每个消费者的处理时间。例如，假设消费者 A 需要 50 毫秒来处理一条消息，而消费者 B 需要 5 秒。理想情况下，消费者 B 应该开始处理 1 条消息，与此同时，消费者 A 应该处理其他 99 条消息。但是，消费者 B 实际上会在 50 秒内处理 25 条消息，而消费者 A 将在大约 4 秒内处理其他 75 条消息，并且将处于空闲状态。客户端 api 似乎预取了消息，这在这种情况下显然不是最佳的。

我们如何解决这个问题？

我们使用的是 Qpid cpp 0.5 和完全托管的 c# 0-10 客户端 API，而不是 cpp 绑定（但我的理解是这种行为与 API 的实现无关）

问候，

朱利安

有没有办法在 Qpid/AMQP 中忽略来自你自己的消息？我已经挖掘了 qpid 的文档和源代码，但找不到让我忽略它们的标志。这似乎是要传递给 exchangeBind() 的东西。