2017-05-26 2 views
1

J'utilise AMQP pour connecter azure Service bus avec le client qpid java avec Spring JMS. J'ai mis à niveau le bus de service vers le niveau supérieur, car le sujet est partitionné par défaut et ne peut pas être modifié à partir de la bibliothèque de gestion du bus de service ou du portail Azure au début de SimpleMessageListenerContainer.Spring jms ListenerContainer avec AMQP utilisant le lancement du client Qpid Exception lors de la connexion au bus Azure Service partitionné

javax.jms.JMSException: Impossible d'ouvrir un client de sujet pour le type d'entité abonné. TrackingId: 74bc8d5-5d05-4239-9dad-cb2133015c29_B19, SystemTracker: servicebus-topic: rubrique: dumb-pipe ~ 127 | sink-alpha-test-processing-subscription, Horodatage: 5/22/2017 2:40:45 PM TrackingId : f572fcfb24dc47bf9ef3968bdfa99666_G17, SystemTracker: gateway2, Timestamp: 22/05/2017 14:40:44 [état = AMQP: non-autorisés]

suivi de: -

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] 

S'il vous plaît noter que tout semble bien (producteur ainsi que le consommateur) lors de l'utilisation sujet non partitionné.

J'ai trouvé que maintenant les entités partitionnées sont supportées par le protocole AMQP avec le bus de service Azure check Latest added features from service bus documentation.

Répondre