文章/答案/技术大牛

发布

社区首页 >问答首页 >带有Qpid的Windows服务总线

问带有Qpid的Windows服务总线
EN

Stack Overflow用户

提问于 2017-05-16 21:55:57

回答 1查看 184关注 0票数 0

我正在尝试使用AMQP为我的项目实现Windows Service Bus 1.1，我已经安装了Windows Service Bus 1.1并使用Service bus Explorer创建了一个名为test的队列，我正在使用以下链接中给出的Java程序测试示例Service Bus功能。

https://msdn.microsoft.com/en-us/library/dn574799.aspx

In the example given above link i have removed if else code starting with if(type.compareTo("onprem") == 0) and hard coded my connection string.

创建生产者，如下所示

Destination que =(目的地) context.lookup("QUEUE")；//读取表单属性文件

生产者= session.createProducer(que)；

My connection string and Queue name looks like the below one
connectionstring = amqps://username:pwd@machinename/SampleNameSpace
QueueName = SampleNameSpace/test

When i run the Java program i am getting the ConcurrentTimeOutException when creating the producer.
I am pretty much new to the Service Bus thing and i tried to find out some solution online but it wasn't successful.

Below is my console log

Initial setup

Creating context

Creating connection factory

Creating connection

Creating session

Creating queue

Creating producer

Exception creating producer
javax.jms.JMSException: java.util.concurrent.TimeoutException
    at org.apache.qpid.amqp_1_0.jms.impl.MessageProducerImpl.<init>(MessageProducerImpl.java:98)
    at org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createProducer(SessionImpl.java:390)
    at org.apache.qpid.amqp_1_0.jms.impl.SessionImpl.createProducer(SessionImpl.java:59)
    at prerna.jms.test.SBTest.main(SBTest.java:71)
Caused by: org.apache.qpid.amqp_1_0.client.Sender$SenderCreationException: java.util.concurrent.TimeoutException
    at org.apache.qpid.amqp_1_0.client.Sender.<init>(Sender.java:178)
    at org.apache.qpid.amqp_1_0.client.Sender.<init>(Sender.java:119)
    at org.apache.qpid.amqp_1_0.client.Sender.<init>(Sender.java:112)
    at org.apache.qpid.amqp_1_0.client.Sender.<init>(Sender.java:98)
    at org.apache.qpid.amqp_1_0.client.Sender.<init>(Sender.java:84)
    at org.apache.qpid.amqp_1_0.client.Sender.<init>(Sender.java:78)
    at org.apache.qpid.amqp_1_0.client.Session$1.<init>(Session.java:90)
    at org.apache.qpid.amqp_1_0.client.Session.createSender(Session.java:89)
    at org.apache.qpid.amqp_1_0.jms.impl.MessageProducerImpl.<init>(MessageProducerImpl.java:86)
    ... 3 more
Caused by: java.util.concurrent.TimeoutException
    at org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint.waitUntil(ConnectionEndpoint.java:1232)
    at org.apache.qpid.amqp_1_0.transport.ConnectionEndpoint.waitUntil(ConnectionEndpoint.java:1214)
    at org.apache.qpid.amqp_1_0.transport.SessionEndpoint.waitUntil(SessionEndpoint.java:681)
    at org.apache.qpid.amqp_1_0.transport.LinkEndpoint.waitUntil(LinkEndpoint.java:355)
    at org.apache.qpid.amqp_1_0.client.Sender.<init>(Sender.java:167)
    ... 11 more


Any help will be greatly appreciated.

windows

service

amqp

bus

回答 1

Stack Overflow用户

发布于 2017-05-17 04:34:35

您似乎正在使用不再受支持的Qpid项目中的遗留AMQP 1.0 JMS客户端。我建议的第一件事是切换到新的AMQP1.0JMS客户端，你可以在Qpid site上找到它。

这是镜像到Github上的Qpid JMS客户端示例的link，这是你的maven dep应该是什么样子。

<dependency>
  <groupId>org.apache.qpid</groupId>
  <artifactId>qpid-jms-client</artifactId>
  <version>0.23.0</version>
</dependency>

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/44003507

复制

相似问题

问带有Qpid的Windows服务总线
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问带有Qpid的Windows服务总线EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问带有Qpid的Windows服务总线
EN