Подключите очередь JMS, используя JNDI с Spring Boot - PullRequest
Новая
       46

Подключите очередь JMS, используя JNDI с Spring Boot

0 голосов
/ 19 декабря 2018

Мне было трудно понять, как реализовать JMS-слушатель Spring Boot, слушая очередь ActiveMQ на сервере приложений JBoss.Поэтому я решил опубликовать вопрос и ответить на него своим окончательным решением, надеясь, что это может сэкономить некоторым из вас несколько часов.

1 Ответ

0 голосов
/ 19 декабря 2018

ActiveMQ поддерживается автоконфигурацией Spring Boot, но, поскольку он находился внутри сервера JBoss, Spring Boot не смог подключиться к ActiveMQ.Фактически вам нужно определить connectionFactory и jmsListenerContainerFactory bean-компоненты самостоятельно, выполнив поиск поставщика JNDI. 

@Configuration
@EnableJms
public class ActiveMqConnectionFactoryConfig {

  @Value("${broker.url}")
  String brokerUrl;

  @Value("${borker.username}")
  String userName;

  @Value("${borker.password}")
  String password;

  @Value("${queue}")
  String queueName;

  private static final String INITIAL_CONTEXT_FACTORY = "org.jboss.naming.remote.client.InitialContextFactory";
  private static final String CONNECTION_FACTORY = "jms/RemoteConnectionFactory";


  @Bean
  public ConnectionFactory connectionFactory() {
    try {
      System.out.println("Retrieving JMS queue with JNDI name: " + CONNECTION_FACTORY);
      JndiObjectFactoryBean jndiObjectFactoryBean = new JndiObjectFactoryBean();
      jndiObjectFactoryBean.setJndiName(CONNECTION_FACTORY);

      jndiObjectFactoryBean.setJndiEnvironment(getEnvProperties());
      jndiObjectFactoryBean.afterPropertiesSet();

      return (QueueConnectionFactory) jndiObjectFactoryBean.getObject();

    } catch (NamingException e) {
      System.out.println("Error while retrieving JMS queue with JNDI name: [" + CONNECTION_FACTORY + "]");
    } catch (Exception ex) {
      System.out.println("Error");
    }
    return null;
  }

  Properties getEnvProperties() {
    Properties env = new Properties();
    env.put(Context.INITIAL_CONTEXT_FACTORY, INITIAL_CONTEXT_FACTORY);
    env.put(Context.PROVIDER_URL, brokerUrl);
    env.put(Context.SECURITY_PRINCIPAL, userName);
    env.put(Context.SECURITY_CREDENTIALS, password);
    return env;
  }

  @Bean
  public DefaultJmsListenerContainerFactory jmsListenerContainerFactory(ConnectionFactory connectionFactory) {

    DefaultJmsListenerContainerFactory factory = new DefaultJmsListenerContainerFactory();
    factory.setConnectionFactory(connectionFactory);
    JndiDestinationResolver jndiDestinationResolver = new JndiDestinationResolver();

    jndiDestinationResolver.setJndiEnvironment(getEnvProperties());
    factory.setDestinationResolver(jndiDestinationResolver);
    return factory;
  }

Затем, если вы хотите использовать очередь, вы просто определяете свой потребительский класс JMS с помощьюметод с комментариями @JmsListener(destination = "${queue}")

 @JmsListener(destination = "${queue}")
  public void receive(Message message) {
    System.out.println("Received Message: " + message);
  }

Надеюсь, это поможет сэкономить несколько часов исследований;)

Приветствия

...