Встроенный брокер RabbitMQ не начинается с приложения загрузки весны

Question

Я не могу отправить сообщение в очередь «CustomerQ» брокер rabbitmq. Я настроил кролик-брокер как встроенный сервер через весеннюю загрузку.

package com.testlab.chapter2; 

    import org.springframework.amqp.core.Queue; 
    import org.springframework.amqp.rabbit.core.RabbitMessagingTemplate; 
    import org.springframework.beans.factory.annotation.Autowired; 
    import org.springframework.context.annotation.Bean; 
    import org.springframework.context.annotation.Lazy; 
    import org.springframework.stereotype.Component; 



    @Component 
    @Lazy 
class Sender { 

    RabbitMessagingTemplate template; 

    @Autowired 
    Sender(RabbitMessagingTemplate template){ 
    this.template = template; 
    } 

    @Bean 
    Queue queue() { 
    return new Queue("CustomerQ", false); 
    } 

    public void send(String message){ 
    System.out.println(template.getRabbitTemplate().getConnectionFactory()); 

    template.convertAndSend("CustomerQ", message); 
    } 
    } 

**application.properties file configuration:** 

    spring.rabbitmq.host=localhost 
    spring.rabbitmq.port=5672 
    spring.rabbitmq.username=guest 
    spring.rabbitmq.password=guest 

Я получаю ниже ошибки, когда код пытается соединиться/поместить любое сообщение в очереди Ошибка:

Servlet.service() for servlet [dispatcherServlet] in context with path [] threw exception [Request processing failed; nested exception is org.springframework.messaging.MessagingException: java.net.ConnectException: Connection refused: connect; nested exception is org.springframework.amqp.AmqpConnectException: java.net.ConnectException: Connection refused: connect] with root cause

java.net.ConnectException: Connection refused: connect at java.net.DualStackPlainSocketImpl.waitForConnect(Native Method) ~[na:1.8.0_25] at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:85) ~[na:1.8.0_25] at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:345) ~[na:1.8.0_25] at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[na:1.8.0_25] at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) ~[na:1.8.0_25] at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172) ~[na:1.8.0_25] at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[na:1.8.0_25] at java.net.Socket.connect(Socket.java:589) ~[na:1.8.0_25]

Я высоко ценю вашу помощь по этому вопросу.

Answer 1

Нет такой вещи, как «встроенный RabbitMQ broker».

Необходимо установить и запустить его отдельно. Он не написан на Java, это Erlang.

Что заставляет вас верить, что Boot внедряет брокера?