问题标签 [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.
jms - 交流和消息优先级
我正在尝试执行以下操作,
- 消息以消息优先级到达消息代理
- 他们根据消息优先级找到进入各种队列的方式
所以 Q1 有优先级为 1 的消息 Q2 有优先级为 2 的消息,依此类推..
有没有办法让 Message Broker 处理 Q1 比其他处理更快。
- 队列之间可以有优先级吗?
- Q1 具有比 Q2 更高的处理优先级或更好的 Q1 处理阻止其他队列被处理?
- 交换本身可以成为优先级队列,进而为其他队列提供数据吗?
- 我看到可以通过插件扩展默认交换,是否有任何东西已经实现了我的上述要求?
这是可行的吗?还是这违反了消息代理的基本理念?
使用优先消息时是否有最佳实践链接?
我确实于 8 月 28 日在 Qpid nabble 论坛上发布了此消息 - 但“此帖子尚未被邮件列表接受”。
感谢您的时间。
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?
java - java.util.InvalidPropertiesFormatException:SAXParseException
我正在尝试将 Apache Qpid 实现到我们的架构中,但在读取属性文件时遇到了问题。
属性 props = new Properties(); props.loadFromXML(this.getClass().getResourceAsStream("hello.properties"));
loadfromxml 给我一个错误,这是堆栈跟踪:
这是 hello.properties 文件:
我究竟做错了什么?我从 Qpid 的文档页面复制了代码片段。
java - AMQP (Qpid) 一对多队列
我有一个生产者,一个队列和 N 个消费者。生产者创建由消费者执行的“工作”。我想使用拉模型,其中消费者从队列中拉出作业,当它完成前一个作业时,而不是使用循环的推送模型,其中作业被等于消费者。
我的消费者使用相同的代码,但是当我运行它时,第一个连接并接收所有工作。即使在调试中查看它,第一个得到所有信息,但第二个 etc 没有收到任何消息(即使它在第一个执行接收之前执行接收,这会返回一些作业)。
连接 URL:“amqp://guest:guest@prodconstest/?brokerlist='tcp://127.0.0.1:5767'”
每个消费者的代码都会:
- 创建 AMQConnection
- 使用自动确认创建队列会话
- 连接开始
- 创建队列
"ADDR:" + queueName + "; {create: always, link:{x-subscribes: {exclusive: false}}}"
- 创造消费者
理论上是否可以使用 AMQP 队列来实现?如果是这样,怎么做?
jms - qpid/amqp jms 客户端的客户端故障转移?
按照 wiki 页面https://cwiki.apache.org/qpid/amqp-java-jms-messaging-client.html到https://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,顺便说一句。
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 并将我们的交换更改为扇出以解决此连接丢失问题,但遇到了问题。
它会“出现”这个链接有点相关:
我首先想知道这是否是正确的方法。
其次,我想了解我们在运行时使用扇出接收到的当前错误,因为我们无法访问数据。以下是收到的错误、WSO2 MB 日志输出和来自生产者的代码片段。
请告知是否需要更多信息来确定。
收到错误...
记录@错误时间...
我发现在尝试连接 Java 时也会出现这个问题。生产者的 C# 代码的简短示例如下:
c++ - 如何在不使用 make 文件的情况下运行 ac 代理示例程序?
我想在不使用 make 文件的情况下在 apache qpid c++ 代理中运行一个 helloworld 示例。如果是这样,如何继续以及我需要包含哪些库?
c++ - 我正在尝试安装 apache qpid 在进行 make 时出现以下错误
我正在尝试通过 svn checkout 安装 apache qpid,我已经安装了所有工具,同时我得到了错误
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 客户端是否真的有效?