Реализация MessageListener в Spring Boot не работает - PullRequest
Новая
       9

Реализация MessageListener в Spring Boot не работает

0 голосов
/ 29 августа 2018

Я пытаюсь реализовать приемник JMS, реализующий MessageListener в приложении Spring-Boot, но, похоже, он не работает.

Я не хочу использовать @JmsListener, так как мне нужен доступ к моему пользовательскому исполнителю задач для многопоточного запуска потребителей в weblogic.

Для этого.

Я реализовал потребитель как показано ниже: 

public class MyJmsListener implements MessageListener {
  @Override
  public void onMessage(Message message) {
      if (message instanceof TextMessage) {
          try {
              String text = ((TextMessage) message).getText();
              System.out.println("received: " + text);
          } catch (JMSException e) {
              e.printStackTrace();
          }
      }
  }
}

AppConfig 

@Bean
  public MessageListenerContainer listenerContainer() {
      DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
      container.setConnectionFactory(connectionFactory());
      container.setDestinationName(QUEUE_NAME);
      container.setMessageListener(new MyJmsListener());
      return container;
  }

Но это не работает в Spring-Boot. Может кто-нибудь сказать, пожалуйста, что здесь не так?

...