qpid

    0热度

    1回答

    下面是我的log4j配置 #log4j.additivity.org.apache.qpid=false log4j.rootLogger=DEBUG, console log4j.appender.console=org.apache.log4j.ConsoleAppender log4j.appender.console.layout=org.apache.log4j.PatternL

    0热度

    1回答

    当谈到JMS队列/主题时,我感到困惑。我想要的是消息应该发送给每个用户,我希望订阅者在活动时从非活动时间接收消息。但是,我无法控制订阅者是否拥有持久订阅。有没有办法建立一个持续队列,并设置它,以便每个用户都会收到相同的消息?以及如何设置这个使用弹簧配置 非常感谢。

    1热度

    1回答

    我试图将我的应用程序的AMQP版本升级到1.0(QPID 0.24.0)。 目前,Connectionfactory URL的格式如下。 amqp://guest:[email protected]/test?brokerlist='tcp://ip1:5672?ssl='true'&ssl_cert_alias='cert1'' 我试图改变URL以下格式,并尝试不同的组合(强力) amqps

    7热度

    1回答

    我想阅读来自服务总线的订阅消息。我正在使用python的qpid-proton库。我正在关注此链接以接收消息Proton-Python-Example-Simple-Receive。我通过这个链接直接从服务总线接收消息 - url = 'amqps://mynamespace.servicebus.windows.net/SharedAccessKeyName=xxxx/SharedAccessK

    0热度

    1回答

    我试图使用Broker Management GUI删除Qpid 上没有的端口接口。 手动进行更改(使用GUI)显示config.json在端口被删除时(使用diff)被修改。 我的代码解决方案使用sed从config.json删除必要的行。 然而,这并不是按预期工作,我认为另一个文件需要修改。 我有diffed整个qpid-broker目录,看到只有config.json使用GUI进行更改。 是

    0热度

    1回答

    spring-amqp可以与AMQP 1.0代理进行通信,保持spring不支持AMQP 1.0版本的事实吗? 我开始了解我打算使用的QPID Proton API,但我宁愿用Spring提供的解决方案来连接AMQP1.0。

    0热度

    1回答

    Proton支持称为“捆绑”的功能,它通过同时发送多个质子消息来更高效地使用带宽。我想刷新所有当前消息,而不是等待。我该怎么做呢? 这是使用0.17版本的C++ API。

    0热度

    1回答

    我使用Apache Camel和Spring从我的Java服务发送消息。如果在交换时发生任何错误,我需要处理/触发某些事件。我正在使用下面的代码来实现我的目标。 try { producerTemplate.sendBody(endPoint, bytes); } catch (final RuntimeCamelException exception)

    0热度

    1回答

    我在写一个发送消息的Qpid客户端。我使用的示例代码: private void runTest() throws Exception { Properties properties = new Properties(); properties.load(this.getClass().getResourceAsStream("helloworld.properties"));

    0热度

    1回答

    我有一个很好的keystore文件。我曾尝试使用下面的命令:: [email protected] # java -Djavax.net.ssl.trustStore=/tmp/apache-servicemix-7.0.0/deploy/qpid.jks SSLPoke esesslx0ghk.se 9443 Successfully connected 现在我使用ServiceMix的部