Tag: qpid

如何从Qpid JMS（qpid-jms-client-0.11.1.jar）发送/接收来自Azure Service Bus的消息？

我目前正在研究如何使用Qpid JMS（qpid-jms-client-0.11.1.jar）连接到Azure Service Bus。 我创建了一个Demo Java应用程序SimpleSenderReceiver，它使用以下指南（ ＃link1 ）连接到已配置的Azure Service Bus。 此代码似乎使用Qpid JMS客户端（版本0.32）的“非常”旧版本。 我现在正试图让它与Qpid JMS的最新稳定版本（qpid-jms-client-0.11.1.jar）一起使用，到目前为止我还没有成功。 通过Qpid JMS 0.11.1的文档#link2 ，您可以看到属性文件中的连接方法与0.32版本中的连接方式不同。 如何在属性文件中设置正确的连接amqp连接字符串 ？ 如何设置de Qpid JMS-Azure Service Bus Demo以使用最新的Qpid稳定版本 ？ 我一直在运行以下问题： 731 [AmqpProvider:(1):[amqps://example-bus.servicebus.windows.net?transport.connectTimeout=60000]] INFO org.apache.qpid.jms.sasl.SaslMechanismFinder – Best match for SASL auth was: SASL-PLAIN javax.jms.JMSException: Idle timeout value specified in connection OPEN (‘30000 ms’) is not supported. Minimum idle […]

独立Apache Qpid（amqp）Junit测试示例

有没有人有一个在独立的 junit测试中使用Apache Qpid的例子。 理想情况下，我希望能够动态创建一个队列，我可以在我的测试中添加/获取msgs。 所以我没有在我的测试中测试QPid，我将使用集成测试，但是测试处理msgs的方法非常有用，不得不模拟一大堆服务。