问题标签 [qpid]

对这两个术语有点困惑，我在想拥有持久消息但瞬态（非持久）队列的目的是什么？毕竟，如果代理重新启动并且队列未恢复，则恢复的消息将被浪费。

问题1 一个困扰我很久的话题。我正在使用（QPID）AMQP 1.0 并尝试启用分布式事务。有没有人设法做到这一点？1.0 规范 ( http://docs.oasis-open.org/amqp/core/v1.0/os/ ) 指出 amqp:distributed-transactions 功能将在第 6 部分中描述，但尚未编写。

有没有人成功地使用 AMQP 1.0 使用分布式事务？

问题2 QPID AMQP 1.0 客户端是否支持分布式事务？

问题 3 Microsoft Azure 服务总线是否支持分布式事务？

我先解释一下我的情况。想要完成的是我的服务器上的多个生产者和多个消费者以及一个代理。我希望消息是持久的，队列是持久的。我希望有多个不会相互干扰的队列。一个队列，一个生产者和一个消费者，这已经很好了。当前代码：

消费者：

制片人：

当然，这些不是整个程序，而是 Qpid 代理中涉及的所有代码。

现在的问题是，如果我为不同的设备创建新的消费者和生产者，并且我想将不同的流量从生产者转移到消费者，那么第一个消费者会从代理窃取所有数据，即使我将其发送到不同的队列，比如 ProdSevenQueue ，并在其他消费者尝试将其存储为不同的本地队列，如“prodseven_local_Queue”。我是否必须以不同的方式使用队列，还是我误解了这里的整个想法？此外，我听到人们谈论配置代理顶部将某些类型的流量重定向到其他地方，但我没有找到这样的例子。推动正确的方向会很棒。更让你困惑的是，这里的情况图片：链接到 imgur

为了我的辩护，我以前从未使用 AMQP 或 Apache Qpid 做过任何事情，而且我还在学习 python。还有一点要抱怨的是，我从未见过比 Apache Qpid 更不连贯的文档。显然不喜欢新玩家。

我正在尝试制作一个通过 AMQP 与 ActiveMQ 集成的 Apache Camel 应用程序。

我一直在使用提供的“ camel-example-spring-jms ”项目，该项目通过标准 TCP 连接，但我已经修改为使用我的独立 ActiveMQ 5.8 安装（而不是嵌入式），我使用 TCP 可以正常工作.

活动 MQ 配置（5672 上的 amqp）

在“ camel-server.xml ”中，我已将现有的“jms”“ActiveMQComponent”替换为“JmsComponent”，该“JmsComponent”引用了“AMQConnectionFactory”，我在其上指定了我的连接 URL（尝试了以下两种变体）。

使用上面的配置，服务器似乎可以正常启动，但是当我将路由添加到“ ServerRoutes.java ”中的 amqp 队列时，启动时出现错误。

Camel Server 窗口中的错误是：

我的 ActiveMQ 窗口中的错误是：

任何帮助都可以诊断此问题。

谢谢。

我正在使用 ActiveMQ 5.8.0，它支持 AMQP 1.0 作为队列代理。我正在尝试使用 Qpid AMQP1.0 客户端 jms 库从 Java 客户端与此通信，但没有看到指定密钥库和信任库信息的方法。

我已经通过 Java VM 选项（例如 -Djavax.net.ssl.keyStore）传入 SSL 凭据成功配置了客户端，但是对于我的最终解决方案来说，这不是可接受的方法......我需要能够指定此信息来自代码中。

我目前正在使用 createFromURL 方法从包含此处定义的 SSL 参数的 URL 生成连接，但似乎没有从 URL 解析密钥库信息（以及可能的故障转移参数）。

有谁知道将安全信息提供到连接中的更好方法？

更新： 对，所以对 API 进行了一些挖掘，我发现该库使用 Default SSLSocketFactory

请参阅：org.apache.qpid.amqp_1_0.client.Connection

因此，似乎无法在 JVM 选项之外指定此信息以设置默认值……至少在当前版本的 Qpid 客户端库中。

We are now using QPID as the AMQP solution instead of Rabbitmq, but I cannot find a easy way to to check queues and topics like Rabbitmq does.

Is there any tool in QPID could do this? I see some qpid-stat, qpid-tool, qpidd but that doesn't help. Any sample or doc available? Can't find much in qpid.apache.org.

Thanks.

我知道 CloudBees 不提供消息队列服务。在我的 Java EE 应用程序中，我使用 RabbitMQ 作为代理，使用 Qpid JMS 作为客户端。它不起作用，原因是：

[#|2013-11-09T20:21:45.203+0000|INFO|glassfish 4.0|org.jboss.weld.ClassLoading|_ThreadID=39;_ThreadName=AutoDeployer;_TimeMillis=1384028505203;_LevelValue=800;| WELD-000119 由于基础类加载错误，未从 javaeetutorial.websimplemessage.SenderBean 生成任何 bean 定义：找不到类型 javax.jms.Message。如果这是意外情况，请启用 DEBUG 日志记录以查看完整错误。|#]

你有什么解决方案让它在 CloudBees 中工作。CloudBees 是否支持 Qpid？

先感谢您。莱昂

首先感谢您花时间研究这个问题。我在 PaaS（Openshift Origin）上启动和运行 qpid 时遇到了一些问题。

我第一次使用钝力方法让它运行，只需将其复制到服务器而不使用 ReST API。我尝试运行 qpid 时遇到的错误如下：

我只是好奇是否有办法将 qpid 绑定到 IP，例如 127.1.244.129

我问的原因是我希望将许多实例部署到 PaaS，并且需要多个正在运行的实例。如果一切都试图绑定到 localhost:8080，这是不可能的。

有谁知道配置这个的方式？我在 qpid 文档中找不到。

我正在研究使用 RabbitMQ 或 ActiveMQ 等产品。我看到这些产品在一定程度上支持 AMQP v1.0。

但是，我正在努力寻找将 AMQP 1.0 与 .NET 一起使用的客户端。到目前为止，我遇到的唯一一个是 Apache Qpid。但是，必须安装它的所有依赖项并构建它，而不是仅仅使用 NuGet 之类的东西来获取客户端库，这一切似乎有点麻烦，并且不给我提供支持前进的信心。

Microsoft Azure 服务总线支持 AMQP 1.0 并有一个客户端，但据我所知，它似乎是特定于该产品的，这很遗憾，因为我认为 AMQP 的好处之一是可以轻松切换不同的代理。

从我在 RabbitMQ 上读到的内容来看，他们似乎没有承诺为 AMQP 1.0 构建客户端。

有没有人对上述有任何想法，是否有我忽略的客户？

提前谢谢了