ActiveMQMessageConsumer получает сообщение только один раз в 5 секунд от темы на Java

Question

Я пытаюсь получить сотни сообщений от темы, используя ActiveMQMessageConsumer на Java.Я добавляю MessageListener для обработки сообщений, и по какой-то причине я получаю сообщение каждые 5 секунд.Как я могу настроить это?Мой код:

Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

final Topic topic = session.createTopic(myTopic);
final MessageConsumer messageConsumer = session.createConsumer(topic);
messageConsumer.receiveNoWait();

messageConsumer.setMessageListener(message -> {
       if (message != null) {
            try {
                System.out.println("A message received: "
                                           + ((TextMessage) message).getText()
                                           + "\n at: " + Instant.now());
            } catch (JMSException e) {
                throw new RuntimeException(e);
            }
        }
    });
Thread.sleep(500000);

Answer 1

Хорошо, проблема была в части приложения, которая генерировала сообщения и организовывала тему.Изменяя его и оставляя Потребительскую часть, как исправлена ​​проблема.