问题标签 [qpid]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
280 浏览

jms - 交流和消息优先级

我正在尝试执行以下操作,

  • 消息以消息优先级到达消息代理
  • 他们根据消息优先级找到进入各种队列的方式

所以 Q1 有优先级为 1 的消息 Q2 有优先级为 2 的消息,依此类推..

有没有办法让 Message Broker 处理 Q1 比其他处理更快。

  • 队列之间可以有优先级吗?
  • Q1 具有比 Q2 更高的处理优先级或更好的 Q1 处理阻止其他队列被处理?
  • 交换本身可以成为优先级队列,进而为其他队列提供数据吗?
  • 我看到可以通过插件扩展默认交换,是否有任何东西已经实现了我的上述要求?

这是可行的吗?还是这违反了消息代理的基本理念?

使用优先消息时是否有最佳实践链接?

我确实于 8 月 28 日在 Qpid nabble 论坛上发布了此消息 - 但“此帖子尚未被邮件列表接受”。

感谢您的时间。

0 投票
1 回答
653 浏览

c# - 在 Windows 上构建 Apache QPID 缺少 setup.py

我是 Apache Qpid、Cmake 和 Python 的新手。我已经在 Debian 上成功构建了 Qpid 并运行了一些测试。我现在正在尝试在 Windows 上构建 Qpid,以便我可以编写 C# 客户端,但似乎有问题。当我运行 cmake 命令时,它最终会给我以下输出:

我试图了解 setup.py 应该何时生成/下载。我找不到它,也找不到任何描述它应该何时生成或安装的文档。另外,有点跑题了,为什么 cmake 进程开始提示我 BUILD_ACL 和其他配置?

我使用以下命令为 VS 2008 和 2010 运行了 cmake,并且都产生了相同的输出:

我正在使用来自 Apache 的以下文件来构建 Qpid:qpid-cpp-0.18.tar.gz

从上面的日志语句中可以看出,我使用的是 Python 3.3.0。

我了解 setup.py 是 Python 用于安装组件的文件。似乎 cmake 脚本正试图根据我通过搜索 setup.py 找到的 cmake 脚本的一部分在测试目录中安装一些东西。我认为这要么是在 Qpid tarball 中提供,要么是作为这个 cmake 过程的一部分生成的。

综上所述,我最终按住了输入键,接受了 cmake 的所有默认值,它生成了解决方案文件和项目文件。我能够在 VS2008 中打开生成的 Qpid 解决方案并构建一些项目。那么,这就提出了一个问题,为什么需要 setup.py?

0 投票
3 回答
3177 浏览

derby - 与 Apache Qpid 一起使用时,Apache Derby 将其文件存储在哪里?

我正在使用Derby DB作为我的Qpid 代理的存储。当作为嵌入式数据库运行时,试图找出 Derby 存储数据文件的位置。

任何人都知道文件的位置或如何设置要使用的目录?

0 投票
1 回答
8265 浏览

java - java.util.InvalidPropertiesFormatException:SAXParseException

我正在尝试将 Apache Qpid 实现到我们的架构中,但在读取属性文件时遇到了问题。

属性 props = new Properties(); props.loadFromXML(this.getClass().getResourceAsStream("hello.properties"));

loadfromxml 给我一个错误,这是堆栈跟踪:

这是 hello.properties 文件:

我究竟做错了什么?我从 Qpid 的文档页面复制了代码片段。

0 投票
1 回答
456 浏览

java - AMQP (Qpid) 一对多队列

我有一个生产者,一个队列和 N 个消费者。生产者创建由消费者执行的“工作”。我想使用拉模型,其中消费者从队列中拉出作业,当它完成前一个作业时,而不是使用循环的推送模型,其中作业被等于消费者。

我的消费者使用相同的代码,但是当我运行它时,第一个连接并接收所有工作。即使在调试中查看它,第一个得到所有信息,但第二个 etc 没有收到任何消息(即使它在第一个执行接收之前执行接收,这会返回一些作业)。

连接 URL:“amqp://guest:guest@prodconstest/?brokerlist='tcp://127.0.0.1:5767'”

每个消费者的代码都会:

  1. 创建 AMQConnection
  2. 使用自动确认创建队列会话
  3. 连接开始
  4. 创建队列"ADDR:" + queueName + "; {create: always, link:{x-subscribes: {exclusive: false}}}"
  5. 创造消费者

理论上是否可以使用 AMQP 队列来实现?如果是这样,怎么做?

0 投票
2 回答
1326 浏览

jms - qpid/amqp jms 客户端的客户端故障转移?

按照 wiki 页面https://cwiki.apache.org/qpid/amqp-java-jms-messaging-client.htmlhttps://cwiki.apache.org/qpid/connection-url-format.html

简单我期望 qpid-amqp-1-0-client-jms-0.20-sources.jar 接受 URI 格式,但它似乎忽略了所有内容 - 特别是“brokerlist”选项?

例如:

但是 ConnectionFactory 坚持使用<clientid>代理主机,并为其添加默认端口。

我确定我在这里遗漏了一些非常明显的东西......

经纪人是 ActiveMQ 5.8.0,顺便说一句。

0 投票
1 回答
1575 浏览

rabbitmq - 将 RabbitMQ C# 与 AMQ/QPID 和 WSO2 消息代理扇出交换一起使用

我正在使用 RabbitMQ 2.8.7 DotNet 客户端和 WSO2 MB 3.2.1。我的部署环境是 Win7 R1 64bit 或 Win Server 08 R2 64bit。我遇到了与 Exchange 的多个连接的问题,因此流向多个消费者的数据会间歇性丢失。我们已尝试将 WSO2 MB 更新为 3.2.3 并将我们的交换更改为扇出以解决此连接丢失问题,但遇到了问题。

它会“出现”这个链接有点相关:

http://wso2-oxygen-tank.10903.n7.nabble.com/Qpid-Authorization-handler-does-not-allow-to-subscribe-td2080.html

我首先想知道这是否是正确的方法。

其次,我想了解我们在运行时使用扇出接收到的当前错误,因为我们无法访问数据。以下是收到的错误、WSO2 MB 日志输出和来自生产者的代码片段。

请告知是否需要更多信息来确定。

收到错误...

记录@错误时间...

我发现在尝试连接 Java 时也会出现这个问题。生产者的 C# 代码的简短示例如下:

0 投票
1 回答
127 浏览

c++ - 如何在不使用 make 文件的情况下运行 ac 代理示例程序?

我想在不使用 make 文件的情况下在 apache qpid c++ 代理中运行一个 helloworld 示例。如果是这样,如何继续以及我需要包含哪些库?

0 投票
0 回答
85 浏览

c++ - 我正在尝试安装 apache qpid 在进行 make 时出现以下错误

我正在尝试通过 svn checkout 安装 apache qpid,我已经安装了所有工具,同时我得到了错误

svn co http://svn.apache.org/repos/asf/qpid/trunk

0 投票
0 回答
170 浏览

qpid - QPID CPP 0.20 和 Java 客户端 AMQP 1.0 之间的无限连接初始化

我正在运行 Qpid 0.20 CPP 代理(符合 AMQP 1.0)并尝试使用 Java 应用程序发送 JMS 消息。

  • 当使用 AMQP 0-10 客户端和org.apache.qpid.jndi.PropertiesFileInitialContextFactory类时起作用(参见第一个 Java 示例

  • 当使用 AMQP 1.0 客户端和类时不起作用(参见第二个 Java 示例):客户端进入无限线程循环并且从未实际发送消息。org.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory

由于Windows Azure 文档明确提到了org.apache.qpid.amqp_1_0.jms.jndi.PropertiesFileInitialContextFactory该类的使用,是不是 Qpid 0.20 CPP 代理不支持 AMQP 1.0 Java 客户端?鉴于http://guest:guest@localhost/test?cliendId='test-client'AMQP 1.0 示例中的连接 url ( ) 无效,我根本不知道代码是否可运行。

有谁知道设置 CPP 代理 - Java AMQP 1.0 客户端是否真的有效?