问题标签 [qpid]

我在尝试使用Visual Studio 2010用boost 1_47_0编译qpid c++ 时卡住了。这是我制作的步骤顺序：

1. 内置升压 1.48.0
2. 在 %PATH% 环境中添加了 BOOST_ROOT、BOOST_INCLUDEDIR、BOOST_LIBRARYDIR 等。多变的
3. 安装了cmake、Python、Ruby并将它们的路径添加到 %PATH% env。多变的
4. 解压 qpid -cpp-0.14.tar.gz
5. 由于boost文件层次结构的最后更改，应用了来自https://bugzilla.redhat.com/attachment.cgi?id=542165&action=diff的补丁
6. 重命名了一些 qpid 所需的 boost 库，从libbost_LIBRARY-vc100-mt-1_48.lib到boost_LIBRARY.lib格式
7. 在'qpidc-0.14'目录下启动“cmake -i -G 'Visual Studio 2010'” ，成功接收到*.vcxproj文件

现在，问题出现了。

我加载了在步骤 7 中创建的 'ALL_BUILD.vcxproj' 文件，并尝试构建一个项目 - qpidcommon。但由于“缺少库”错误，我不能。我再次将boost库从libbost_LIBRARY-vc100-mt-1_48.lib 重命名为boost_LIBRARY-vc100-mt-1_48.lib文件格式并尝试编译。

而且，至少，我收到了下一个：

我不知道如何处理这个问题，而不是直接向项目添加库。你？

谢谢。

QPID AMQP

我有一个问题正在重新调整网络流量。假设我在 Machine A 上有一个 Publisher 。Qpid 代理正在 Machine B 上运行。我们有两个订阅者机器 C 和机器 D（他们都订阅相同的主题）。现在想象一个拓扑，其中
A-->B-->X-->C | D（发布者A连接到B，订阅者C和D通过中间节点X连接到代理）由A发布的匹配C和D主题的消息将被两者接收。我想知道的是边 b->x 是否会携带消息两次（一次用于 b->x->c，第二次用于 b->x->c）。或者 AMQP/qpid 框架是否足够智能，可以从 B 向 X 发送一次消息，然后向每个单独的订阅者发送副本（因此 b->x 上的网络流量较少）。我的想法是，由于 X 一无所知，并且如果我们为每个订阅者都有私有订阅队列（或者即使共享队列和浏览/复制消息而不是消费），消息将通过 b->x 传输两次

这个问题并不特定于 QPID 。我想知道其他基于代理（RabbitMQ）和无代理消息传递框架（零 MQ，LBM/UMS）的解决方案。我在一篇文章中读到 Zero Mq 试图提供更智能的解决方案http://www.250bpm.com/pubsub#toc4，但这似乎很复杂，因为中间跃点如何知道何时发送多个副本（我不是网络专家，所以我可能会遗漏一些明显的东西，所以任何帮助都将不胜感激）

如何使用python上的qpid 库接收存储在队列中的消息量？

我试过这样：

它总是给我返回 0 条消息。

我有一个带有以下参数的 qpid 队列： bus-sync-queue --durable --file-size=48 --file-count=64

我想将1 000 000条消息放入此队列。每条消息只是一个12 个字符的字符串。（002000333222、002000342678 等）。我必须为 config --file-size= X --file-count= Y设置什么值才能将所有消息放入队列？

我正在使用 qpid 消息传递库。我有一个包含连接对象的单例类。我注意到我的应用程序将在退出时成为核心，具体取决于我创建连接的方式。如果我在单例构造函数或静态方法中创建它，一切都很好，但是如果我在非静态方法或 getinstance 方法中创建它，如下所示，消息传递库将在调用我的析构函数之前在内部调用 close 方法它会调用中止。我想知道这些创建调用有什么不同可能导致这样的结果。

我将 QPid 与 Eclipse 和 Tomcat 一起使用。创建了一个动态 Web 应用程序并设置了 QPID_HOME、QPID_WORK 环境变量。

试用这里提到的 Hello.java 示例：-

https://svn.apache.org/repos/asf/qpid/trunk/qpid/java/client/example/

但是我在运行这个文件时遇到了这些错误：-

我正在研究找出我们未来产品的消息传递解决方案，但我无法真正弄清楚这一点。

有一堆 AMQP 0.9.1 实现（RabbitMQ、Apache Qpid、OpenAMQ 等等），但没有 AMQP 1.0 实现，尽管 1.0 已在 2011 年 10 月完成。好吧，除了 SwiftMQ [1]。

阅读 1.0，它似乎与 1.0 之前的规范大相径庭，因此似乎可以理解，对工作正常的东西进行重大重写的热情不大。事实上，我不明白为什么 RabbitMQ 和其他人不会直接决定迁移到 ZeroMQ 而不是 AMQP 1.0。

尽管如此，我仍然找不到 1.0 之前的 AMQP 规范的实现者对此的任何明确声明，除了一些模糊的承诺，例如“努力始终实现最新的 AMQP 规范”。

编辑： RabbitMQ 实际上确实说

RabbitMQ 的未来版本将实现 AMQP 1.0。请联系我们。

但是，有些事情告诉我，该声明已有 3 年多的历史了，即它早于 AMQP 1.0 的发布。

那么是否有任何迹象表明 AMQP 1.0 可能成为标准，除了主要银行和微软支持它的事实吗？后者顺便说一句。没有自己的实现。

似乎 AMQP 0.9.1 比 1.0 更标准。

嗯，有https://github.com/rabbitmq/rabbitmq-amqp1.0，它的自称状态是原型，显然有半年没有工作了。

[1] 我对 SwiftMQ 的第一印象是通过它的作者对 Spring 缺乏 AMQP 支持的咆哮，这也是我暂时不考虑它的原因。我不想指望那个家伙的支持。

首先感谢提供平台讨论问题。

我发现 qpid cpp 客户端程序有问题。

在 subscriptions.start 之后，如果我向客户端程序发送任何消息，我可以看到消息已收到，但它失败并出现以下异常。

堆栈说..

我在这里错过了什么吗？

请帮我。

我应该使用什么地址将队列绑定到使用 Qpid 的标头交换？我希望队列只接收具有特定标头和值的消息吗？

我有一堆线程，每个线程创建一个org.apache.qpid.client.AMQConnection，然后创建一个会话。

在某些运行中，我在两个不同的线程中得到相同的 Session.hashCode() ，如下所示：

现在我明白hashcode()了不能保证是唯一的，我如何证明或反驳createSession()在两个单独的线程上返回相同的会话对象？