qpid

    0热度

    4回答

    是否有任何选项可以在Apache Qpid的消息级别设置路由密钥。 我现在的做法是 在地址字符串中指定路由键。用这个目的地址创建一个制作人。 topic =(Topic)context.lookup(“destination”); sender = session.createProducer(topic); 通过制作人发送消息。 这样所有的消息都有相同的路由密钥。我想实现的是为每个消息分别设置一

    0热度

    1回答

    我正在使用qpid消息库。我有一个持有连接对象的单例类。我注意到我的应用程序将核心退出取决于我如何创建连接。如果我在单例构造函数或静态方法中创建它,一切都很好,但是如果我使用非静态方法创建它,或者在我的getinstance方法中创建它,则消息库在调用析构函数之前会在内部调用close方法它会调用一个中止。我想知道这些创作电话是不同的,可能会导致这样的结果。 class Singleton : p

    1热度

    1回答

    我正在寻找在高消息流量下发出C++ Apache QPID客户端以获得最佳性能的最佳方式。 我们的经纪人将包括3个交易所,每个交易所有2个单向队列。在3“上行链路”队列中将会有大量的流量,这是C++客户端推动的。 有几个稀疏记录的类用于与QPID代理进行接口。连接,会话,发件人和接收者。连接提供会话,会话提供发送者或接收者。在阅读各种QPID文档后,我不清楚哪些对象是线程安全的(或者不是线程安全的

    0热度

    2回答

    我试图从python的amqp代理接收消息。这里是我的代码: #!/usr/bin/python import sys import os import getopt from qpid.messaging import * from qpid.log import enable, DEBUG broker_rcv = "admin/[email protected]:IP" a

    0热度

    1回答

    Apache qpid没有直接支持发送日期类型对象。我想发送 datetime从使用Apache Qpid的数据库和日期对象中获取,可以跨不同系统移植,即使用C++/Java或任何其他语言使用Apache qpid的系统。 我该如何做到这一点,以便像时区分辨率等所有常见的东西都照顾W/O任何问题。

    1热度

    1回答

    Apache Qpid Java客户端API有一个AMQConnection类,用于建立与Qpid消息代理的连接。我正在使用单个字符串构造函数(AMQConnection(String connection))。我有一个实用程序方法,首先创建连接字符串,然后传递给AMQConnection构造函数。 连接字符串的格式为amqp://<username>:<password>@<clientID>/

    0热度

    1回答

    我坚持试图编译qpid C++使用Visual Studio 2010中提升1_47_0。 下面是步骤的顺序,我做: 内置升压1.48.0 新增BOOST_ROOT,BOOST_INCLUDEDIR,BOOST_LIBRARYDIR等方面%PATH%ENV。可变 安装cmake的,的Python,红宝石和加入它们的路径到%PATH%ENV。可变 Untared qpid-CPP-0.14.tar.

    1热度

    1回答

    我在Eclipse和Tomcat中使用QPid。创建一个动态Web应用程序并设置QPID_HOME,QPID_WORK环境变量。 试行这里提到的Hello.java例如: - https://svn.apache.org/repos/asf/qpid/trunk/qpid/java/client/example/ 但是在运行这个文件我得到这些错误: - Exception in thread "m

    2热度

    2回答

    如何接收存储在队列中的消息数量qpid库 on python? 我已经试过这样: from qpid.messaging import * broker_rcv = connect_address address_rcv = queue_name + "; { node: { type: queue }, assert: never , create: never, mode: " + "b

    2热度

    1回答

    我有一个qpid队列与该参数: 总线同步队列--durable --file尺寸= 48 --file计数= 64 欲放入队列消息。每条消息只是一个字符串,包含个字符。 (002000333222,002000342678等)。我必须设置什么值来配置--file-size = X --file-count = Y能够适合所有消息排队吗?