qpid相关内容
我正在研究找出适合我们未来产品的消息传递解决方案,但我真的无法弄清楚这一点. 有很多 AMQP 0.9.1 实现(RabbitMQ、Apache Qpid、OpenAMQ 等等),但没有 AMQP 1.0 实现,尽管 1.0 已在 2011 年 10 月完成.好吧,除了 SwiftMQ [1]. 阅读 1.0 后,它似乎与 1.0 之前的规范大相径庭,因此似乎可以理解的是,对运行良好的
..
我的应用程序需要高性能消息总线,因此我正在评估 ZeroMQ、RabbitMQ 和 Apache Qpid 的性能.为了测量性能,我正在运行一个测试程序,该程序使用其中一个消息队列实现发布 10,000 条消息,并在同一台机器上运行另一个进程来使用这 10,000 条消息.然后我记录发布的第一条消息和收到的最后一条消息之间的时间差. 以下是我用于比较的设置. RabbitMQ:我使用了
..
我正在尝试制作一个通过 AMQP 与 ActiveMQ 集成的 Apache Camel 应用程序. 我一直在使用提供的“camel-example-spring-jms"项目工作,该项目通过标准 TCP 连接,但我已修改为使用我的独立 ActiveMQ 5.8 安装(而不是嵌入),我使用 TCP 工作正常. 活动 MQ 配置(5672 上的 amqp)
..
我想使用JMS将计划的消息发送到Azure服务总线.我的代码基于 org.apache.qpid.jms.message.JmsMessage .我已经找到了解决给定问题的一种解决方案,但是它使用的是 org.apache.qpid.proton.message.Message ,该代码具有 .getMessageAnnotations(),该代码可以进行编辑消息注释,并添加一些可由Azure S
..
我想实现一个从amqp到mqtt的适配器,该适配器将接收amqp消息,获取其有效负载并将其作为mqtt消息发布到我的mqtt代理.因此,适配器必须能够 在端口上听 确认连接请求 接收amqp消息 确认他们 使用mqtt发布 在我的生态系统中,我想为传入消息提供不同的协议,但是我只想运行一个mqtt代理.我想避免其他经纪人.我在这里 amqp"1.0允许无代理点对点通信".我想这
..
使用SOCKS代理或任何其他代理,对于无法直接访问Internet或防火墙禁止amqps连接端口的环境,有什么方法可以使用org.apache.qpid.jms.JmsConnectionFactory通过SSL连接到amqp队列. 我已经尝试在可以使用Internet的环境中使用org.apache.qpid.jms.JmsConnectionFactory通过SSL连接到amqp队列.它
..
构建qpid-proton-0.17.0程序时,出现此链接错误: 对质子:: event_loop :: inject(std :: function)的未定义引用 这是我的建造方式: g ++ -std = c ++ 14 myprog.cpp -o myprog -lqpid-质子-cpp -lboost_system -lcrypto -lssl 我想念图书馆
..
我正在尝试通过使用Jms Qpid客户端的Spring Boot应用程序使用Apache Qpid.我可以配置它,但是当我尝试从队列中接收消息时,记录器正在打印: Dispatcher(918480905)Received a message(878303980)[1] from queue 1 )without a handler - rejecting(requeue)... 这是我
..
嗨,我正在使用嵌入式代理Qpid测试Spring集成项目.但是问题是我如何在qpid中进行队列和交换.我以为Rabbit-config.xml会在qpid代理中进行队列和交换,但无济于事.我的流程是创建队列,并在qpid代理中进行交换,将消息传递给它们,绑定到这些队列的入站amqp适配器将获得消息,我可以继续进行测试 错误:队列:在VirtualHost“默认"上找不到"push.custo
..
使用QPID Java客户端,我只能使用以下AMQAnyDestination扩展语法将通过交换传递的消息获取到绑定队列中 Destination queue = new AMQAnyDestination( new AMQShortString("onms2"), new AMQShortStr
..
我正在尝试在我们非常小的和简单的Spring Boot应用程序中跟踪和识别导致内存泄漏的根本原因. 它使用以下内容: -Spring Boot 2.2.4 -azure-servicebus-jms-spring-boot-starter 2.2.1 -MSSQL 功能: 该应用程序仅调度Azure ServiceBus队列并存储数据,并将数据发送到其他目标. 这是一个小型应用程序,因
..
这是我使用Apache Proton和Qpid(java-broker版本0.32)的第一天,我需要一个简单的Java发送和接收示例(无JMS).通过四处浏览,我发现Send.java和Recv.java都不起作用. 在"mng.send()上,我得到 java.io.IOException: An established connection was aborted by the s
..
我正在尝试使用python-qpid-proton版本0.9.1将消息发送到Azure服务总线队列. examples/python/messenger/中的示例接受格式为amqps://:@/的地址,因此我可以成功地将消息发送到我在Azure上拥有的队列中.问题是我无法控制很多事情,也就是说,我真的看不到发送是否失败.
..
当前,我正在处理某些与RabbitMQ交互的Spring Boot 2.x应用程序. 我想创建一个集成测试来测试整个应用程序.逻辑,包括与Rabbit互动.到目前为止,我需要轻巧的AMQP标准独立实现来使Spring Boot与其配合使用,包括发送&接收消息.我在这里 但它需要RabbitMQ在对我的IT不太有利的地方运行.还有其他成熟的轻量级独立AMQP实现吗? 首先感谢您的协助.
..
我在Windows XP上构建qpid cpp解决方案时遇到了困难 我已经安装了Boost 1.55.0,Python 2.7,Ruby 2.0.0和CMake 2.8 然后我为Python,Ruby和CMake添加了环境变量路径,然后Boost变量是 设置如下 BOOST_ROOT C:\ Boost BOOST_LIBRARYDIR C:\ Boost \ lib
..
我正在考虑使用RabbitMQ或ActiveMQ之类的产品.我看到这些产品在一定程度上对AMQP v1.0提供了一定程度的支持. 但是,我正在努力寻找将AMQP 1.0与.NET结合使用的客户端.到目前为止,我遇到的唯一一个是Apache Qpid.但是,必须安装所有依赖项并进行构建,而不仅仅是使用诸如NuGet之类的方法来获取客户端库,这似乎有点麻烦,并且没有使我对支持向前发展充满信心.
..
我有兴趣从Python脚本监听事件中心,并在检测到入站消息时执行一些代码. 在Ubuntu上,将Python 2.7与 https://pypi.python.org一起使用/pypi/python-qpid-proton/0.10 和示例“接收器"脚本,我尝试订阅一个看起来像这样的URI: amqps://:@.servicebus
..
我正在做研究,以确定可以为我们的未来产品选择哪种消息传递解决方案,而我真的无法弄清楚这一解决方案. 有很多AMQP 0.9.1实现(RabbitMQ,Apache Qpid,OpenAMQ,仅举几例),但没有AMQP 1.0实现,尽管1.0已于2011年10月完成.嗯,除了SwiftMQ [1]. 从1.0开始阅读,似乎与1.0之前的规范有很大的出入,因此可以理解,对于工作良好的东西进
..
我使用的是ActiveMQ 5.8.0,它支持AMQP 1.0作为队列代理。我正在尝试使用Qpid AMQP1.0客户端jms库从Java客户端与之通信,但是看不到指定密钥库和信任库信息的方法。 通过通过Java VM选项(例如-Djavax.net.ssl.keyStore)传入SSL凭据成功配置了客户端,但是对于我的最终解决方案,这不是可接受的方法...我需要能够指定此信息 我目前
..
我的应用程序需要高性能的消息总线,因此我正在评估ZeroMQ,RabbitMQ和Apache Qpid的性能.为了衡量性能,我正在运行一个测试程序,该程序使用消息队列实现之一发布10,000条消息,并在同一台计算机上运行另一个进程以消耗这10,000条消息.然后,我记录发布的第一条消息和收到的最后一条消息之间的时间差. 以下是我用于比较的设置. RabbitMQ:我使用了“扇出"类型交
..