Question

J'ai ci-dessous le pseudo code de flux qui utilise la file d'attente pour envoyer le message, puis écouter le sujet de manière synchrone. Le fournisseur JMS sous-jacent est TIBCO EMS.

//Send to Queue
Connection connection = createConnection(); // get the JMS connection
Session session = connection.createSession(false, javax.jms.Session.AUTO_ACKNOWLEDGE);
Queue queue = session.createQueue("sample.queue");
MessageProducer messageProducer =  session.createProducer(queue);
Message message = createMessage(); //create JMS message
messageProducer.send(message);

Maintenant, j'écoute un sujet en utilisant la même chose session objet créé et attendez qu'il y ait une réponse.

Topic topic = session.createTopic("sample.topic");
MessageConsumer messageConsumer =  session.createConsumer(topic);
//wait for the reply.
Message responseMessage = messageConsumer.receive(60000);
if(responseMessage != null) {
    System.out.println("Message received..");
}

Le problème auquel je suis confronté est que l'objet de message sort comme nul. J'ai testé avec un outil de surveillance JMS et le sujet a un message, mais le code ci-dessus n'est pas en mesure de le récupérer même après 60 secondes.

Une idée de ce qui me manque ici?

Pas de solution correcte

Licencié sous: CC-BY-SA avec attribution
Non affilié à StackOverflow
scroll top