Comportement synchrone avec le sujet JMS
-
29-10-2019 - |
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