Подключение к встроенному ActiveMQ из другого проекта Spring Boot - PullRequest
Новая
       9

Подключение к встроенному ActiveMQ из другого проекта Spring Boot

0 голосов
/ 29 января 2019

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

, повторная попытка с использованием FixedBackOff {interval = 5000, currentAttempts = 113, maxAttempts = unlimited}.Причина: не удалось подключиться к URL-адресу брокера: tcp: // localhost: 61616.Причина: java.net.ConnectException: соединение отклонено (соединение отклонено)

Ниже приведены мои конфигурации в потребительском проекте. 

@Configuration
@EnableJms
public class Config {

    @Autowired
    ConnectionFactory connectionFactory;

    @Autowired
    MessageListener messageListener;

    @Bean
    public ActiveMQQueue getQueue(){
        return new ActiveMQQueue("my.queue");
    }

    @Bean
    public ActiveMQConnectionFactory getActiveMQConnectionFactory(){
        ActiveMQConnectionFactory activeMQConnectionFactory = new ActiveMQConnectionFactory();
        activeMQConnectionFactory.setBrokerURL("tcp://localhost:61616");
        //activeMQConnectionFactory.setBrokerURL("vm://localhost");
        return activeMQConnectionFactory;
    }

    @Bean
    public JmsTemplate getJmsTemplate(){
        return new JmsTemplate(activeMQConnectionFactory());
    }

    @Bean
    public MessageListenerContainer getContainer() {
        DefaultMessageListenerContainer container = new DefaultMessageListenerContainer();
        container.setSessionAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
        container.setConnectionFactory(connectionFactory);
        container.setMessageListener(messageListener);
        container.setDestinationName("my.queue");
        return container;
    }

Как подключиться к работающему встроенному ActiveMQна другом проекте?Оба проекта работают на одном и том же виртуальном компьютере.

...