Я использую ActiveMQ Artemis для простого чата. Отправка сообщения работает нормально, и потребитель использует сообщение, выполнив onMessage(). Но ни onCompletion(), ни onException() методы javax.jms.CompletionListener не выполняются.
ConnectionFactory factory = new ActiveMQConnectionFactory("tcp://TJ12AA041-PC:61616");
Connection con = factory.createConnection();
con.start();
Session session = con.createSession(false, Session.AUTO_ACKNOWLEDGE);
Topic topic = session.createTopic("examp2");
MessageProducer producer = session.createProducer(null);
TextMessage txt = session.createTextMessage();
txt.setText("Hello Hello");
producer.send(topic, txt, new CompletionListener() {
@Override
public void onException(Message msg, Exception ex) {
System.out.println("Failed to send Messaeg : "+ex.getMessage());
}
@Override
public void onCompletion(Message msg) {
System.out.println("Message sent SuccessFully");
}
});