2017-05-26 141 views
1

我正在使用AMQP將Jasure服務總線與Java qpid客戶端一起連接到Spring JMS。Spring jms ListenerContainer與使用Qpid客戶端的AMQP拋出異常連接到Azure服務總線分區時主題

我將服務總線擴展到高級層,因爲主題是默認分區的,無法從門戶或Azure服務總線管理庫修改我在SimpleMessageListenerContainer的開始處遇到以下問題。

的javax.jms.JMSException無法打開一個主題客戶端的實體類型用戶。 TrackingId:74bcb8d5-5d05-4239-9dad-cb2133015c29_B19,SystemTracker:servicebus-topic:topic:dumb-pipe〜127 | sink-alpha-test-processing-subscription,時間戳:2017/5/22 2:40:45 TrackingId :f572fcfb24dc47bf9ef3968bdfa99666_G17,SystemTracker:網關2,時間戳:2017年5月22日下午二時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: [email protected] 

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] 

請注意,一切當使用未分區主題時似乎很好(生產者以及消費者)。

我發現現在使用Azure服務總線check Latest added features from service bus documentation的AMQP協議支持分區實體。

回答

相關問題