问题标签 [qpid]

我尝试执行以下代码，但不幸的是我收到以下错误。任何建议都非常感谢。我在 c:\Python27\Lib\site-packages 中有以下文件
1) cproton.py
2) proton.py
3) _cproton.so

错误：

我是使用 AMQP 的新手，并且正在寻找平台中立的方式来处理消息传递，我们决定在 Java 应用程序中使用 AMQP。但是当我读到AMQP 是线级协议时，它在链接http://www.amqp.org/resources/developer-faqs和 HTTP(GET, POST, PUT, DELETE - 只有我假设，不确定）它具有参考AMQP 执行部分和http://en.wikipedia.org/wiki/Advanced_Message_Queuing_Protocol上的链接协议的 标准消息类型，还有一些请求-响应会话。交换和路由键等概念与绑定队列在http://www.wmrichards.com/amqp.pdf但是当我使用 AMQP-JAVA 搜索示例时，我遇到的只是带有 ActiveMQ 或 QPid 的普通 JMS API 示例，其中使用了 JMS 概念，如目的地、连接、会话等。如果我问的是一个非常笼统的问题，请原谅我，但我真的想通过演示关键字线级协议来理解 JAVA 中的 AMQP 请提出一些示例或参考，或者让我知道我是否在这里完全遗漏了一些东西

谢谢

我没有找到任何关于使用 Apache qpid 甚至一般的 AMQP 实现请求响应的文档或示例，这是受支持且有效的解决方案吗？任何相关信息将不胜感激。

因为我使用的是弹簧和弹簧集成，所以任何内置的支持都会很高兴知道。

谢谢

我有一个使用 spring 集成和 amqp 实现的请求/回复。请求可能需要很长时间才能处理（在某些情况下甚至可能需要一个小时），由于某种原因客户端抛出异常 -

我的客户端配置如下。

我相信回复超时默认值为-1，表示无限期等待，但不确定为什么它不起作用，任何帮助将不胜感激。

在 amqp 中实施如此长时间的等待操作是否还有任何已知问题，或者应该没问题？

谢谢你

我正在使用 Azure 云服务总线使用 AMQP 协议发送和接收消息。我已经在我的 debian-linux 中安装了 proton-c 库。我尝试了以下程序从队列发送和接收消息。我的要求是我使用主题而不是队列。请任何人给我一个示例程序以在 Azure 云中使用主题。

如果我给出主题名称，而不是上面 url 中的 queuename，那么程序将永远运行。请有人帮助我。我是 python 编程的新手。

我正在使用 Java QPID 代理进行测试。我能够使用质子客户端发送和接收消息，但使用匿名身份验证。我有兴趣在启用身份验证的情况下进行测试，并了解质子客户端不支持（尚）。因此，我下载了 rabbitMQ 客户端 jar。我正在使用密码文件身份验证（QPID 附带）。

我像这样设置我的 RabbitMQ 客户端连接工厂：

代码在这一行失败（特别是在 getConnection 上）。

这是一个例外：

java.io.IOException：未找到兼容的身份验证机制 - 服务器在 com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:309) 在 com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory) 提供 [CRAM-MD5] .java:590) 在 com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:612) 在 com.vue.rabbit.core.RabbitMQConnectionFactory.getConnection(RabbitMQConnectionFactory.java:37) 在 com.vue.rabbit.producer。 SimpleProducer.main(SimpleProducer.java:25)

如果我将 QPID 代理更改为使用匿名身份验证，并且还更改客户端不设置用户/密码，我会得到类似的异常“服务器提供 [ANONYMOUS]”

难道我做错了什么？这些应该兼容吗？有点不同的问题是，如果 Java 和 C++ QPID 代理都支持相同的在线 AMQP 协议，为什么会有它们？提前感谢您的帮助！

我正在做一个项目，我需要能够通过 Qpid 发送字节数组，但 Variant 不知道数组是什么。有什么办法，我可以将字节数组转换为 Variant，比如 unit8 的 Variant::list 或 Variant::string，然后当我得到响应时，我可以将字符串或列表转换回字节[]？

谢谢，

我无法从我的 centos 虚拟机中卸载 qpid。我试过以下::

-sudo yum 删除 qpid-cpp-server -sudo yum 删除 qpid-cpp-server

但它没有得到卸载。

我正在使用带有 Apache Qpid (0.3) 作为 Java 客户端的 Azure 服务总线队列（AMQP 协议）。
我还使用 Spring JmsTemplate 来生成消息，并使用 DefaultMessageListenerContainer 来管理我的消费者，spring JMS 4.0.6。

弹簧配置：

配置中没有什么花哨的，只是直截了当。

运行代码，一切似乎都在工作..但是在队列中没有流量的几分钟后，消费者似乎正在失去与队列的连接并且没有接收消息。

我不知道它是否相关，但每隔 5 分钟就会收到以下警告：

我有消息在队列中排了几个小时，只有当我重新启动应用程序时消费者才正确地更新连接并获取消息时才被消费者处理。

问题可能出在 Spring Listener 容器属性或 qpid 连接工厂，还是 Azure 服务总线的问题？

找不到与我的情况相关的帖子将不胜感激！

所以我对此有点难过。我在 C++ 端有一个 AMQP 类实现，最终将我的 Porotocol 缓冲区对象序列化为字符串：

消息体设置为此，内容类型为二进制。

在 Java 端，我们从 JMSBytesMessage 对象中读取字节，然后尝试将数据解析回协议缓冲区对象：

我也试过：

这给出了相同的。

当我记录字节数据时，我确实看到了字节值（使用 Array.ToString(byte[])，但上面的 java 端代码抛出了 InvalidProtocolBufferException：

我假设因为它是字节数据，所以它对字符编码是匿名的。我错过了一些明显的东西吗？此外，无论这看起来多么尴尬，请不要提供替代实施建议，只要假设必须使用这个。任何指导将不胜感激。

协议缓冲区字节数组值（可能不需要？为什么不）编辑：差异字节结果，很有趣。

编辑：顶部用 Java 解码，底部用 C++ 编码：

10 0 18 0 34 0 42 0 50 0 58 0 82 0 90 0 98 0 106 0 114 0 122 0 -126 1 6 97 99 99 101 112

10 0 18 0 34 0 42 0 50 0 58 0 82 0 90 0 98 0 106 0 114 0 122 0 130 1 6 97 99 99 101 112

这些只是最初的几个，但这种模式仍在继续。大部分数据是一样的，只是有些字节从无符号变为有符号。我不太会用 Java 工作，所以这里发生了什么？