Spring jms ListenerContainer与AMQP使用Qpid客户端抛出异常，同时连接到Azure服务总线分区主题

Question

我使用AMQP连接Azure服务总线与java qpid客户端以及Spring JMS。

我将服务总线扩展到了高级层，因为主题在默认情况下是分区的，不能从门户或Azure服务总线管理库进行修改，我在SimpleMessageListenerContainer的开头遇到了以下问题。

javax。jms。JMSException:无法为实体类型订阅服务器打开主题客户端。TrackingId:74bcb8d5-5d05-4239-9dad-CB2133015C29B19，SystemTracker:servicebus主题：主题：哑管~127 |接收器阿尔法测试处理订阅，时间戳：2017年5月22日2:40:45下午TrackingId:F57FCFB24DC47BF9EF3968BDFA99666_G17，SystemTracker:gateway2，时间戳：2017年5月22日2:40:44下午[条件=amqp:不允许]

接着是：-

2017-05-22 16:40:44.772  INFO 14268 --- [windows.net:-1]] o.a.q.j.s.SaslMechanismFinder            : Best match for SASL auth was: SASL-PLAIN
2017-05-22 16:40:45.376  INFO 14268 --- [windows.net:-1]] o.a.q.j.JmsConnection                    : Connection ID:c27375bc-e3e2-41a9-90a4-8e1bb1e17f8a:1 connected to remote Broker: amqps://servicebus-topic.servicebus.windows.net?amqp.idleTimeout=500000

2017-05-22 16:40:45.377  INFO 14268 --- [           main] o.s.j.c.CachingConnectionFactory         : Established shared JMS Connection: org.apache.qpid.jms.JmsConnection@805849

2017-05-22 16:40:46.499  WARN 14268 --- [windows.net:-1]] o.a.q.j.p.a.b.AmqpResourceBuilder        : Open of resource:(JmsConsumerInfo: { ID:c27375bc-e3e2-41a9-90a4-8e1bb1e17f8a:1:1:1, destination = dumb-pipe }) failed: Cannot open a Topic client for entity type Subscriber. TrackingId:74bcb8d5-5d05-4239-9dad-cb2133015c29_B19, SystemTracker:servicebus-topic:topic:dumb-pipe~127|sink-alpha-test-processing-subscription, Timestamp:5/22/2017 2:40:45 PM TrackingId:f572fcfb24dc47bf9ef3968bdfa99666_G17, SystemTracker:gateway2, Timestamp:5/22/2017 2:40:44 PM [condition = amqp:not-allowed]

2017-05-22 16:40:46.520  WARN 14268 --- [           main] ationConfigEmbeddedWebApplicationContext : Exception encountered during context initialization - cancelling refresh attempt: org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'domainListenerContainer' defined in class path resource [ServiceBusConfig.class]: Invocation of init method failed; nested exception is org.springframework.jms.UncategorizedJmsException: Uncategorized exception occurred during JMS processing; nested exception is javax.jms.JMSException: Cannot open a Topic client for entity type Subscriber. TrackingId:74bcb8d5-5d05-4239-9dad-cb2133015c29_B19, SystemTracker:servicebus-topic:topic:dumb-pipe~127|sink-alpha-test-processing-subscription, Timestamp:5/22/2017 2:40:45 PM TrackingId:f572fcfb24dc47bf9ef3968bdfa99666_G17, SystemTracker:gateway2, Timestamp:5/22/2017 2:40:44 PM [condition = amqp:not-allowed]

请注意，当使用未分区的主题时，一切看起来都很好（生产者和消费者）。

我发现AMQP协议支持现在已分区的实体，Azure service bus check是service bus文档中最新添加的功能。

Answer 1

有关如何将Java消息服务（JMS）API与服务总线和AMQP 1.0配合使用的Azure官方教程。如果你非常熟悉sping-jms来连接Azure服务总线分区主题，我认为你可以尝试将教程中的示例代码（基于geronimo jms，JMS标准的实现）与Spring JMS集成在一起。

Answer 2

您可能已经为主题创建使用了默认值，并且启用分区已打开。关闭分区重新创建主题，一切正常。

你可以按照博客中给出的例子，

http://ramblingstechnical.blogspot.in/p/using-azure-service-bus-with-spring-jms.html