Windows Service Bus avec Qpid

Question

J'essayais d'implémenter Windows Service Bus 1.1 avec AMQP pour mon projet, J'ai installé Windows Service Bus 1.1 et créé une file d'attente avec le test de nom en utilisant Service Bus Explorer, Je suis en train de tester l'échantillon fonctionnalité de bus de service avec le programme Java données dans le lien ci-dessous,

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. 

Et la création du producteur comme ci-dessous

Destination = que (Destination) context.lookup ("QUEUE"); // lecture du fichier de propriétés du formulaire

producer = 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. 

Answer 1

Vous semblez utiliser le client JMS AMQP 1.0 hérité du projet Qpid qui n'est plus pris en charge. La première chose que je suggère est de passer au nouveau client JMS AMQP 1.0 que vous pouvez trouver sur le Qpid site.

Voici un link pour les exemples de clients Qpid JMS reflétés sur Github, et voici à quoi devrait ressembler votre dépôt maven.

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