在Spring-Boot中停止RabbitMQ-Connection

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {

    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost("localhost"); // 设置RabbitMQ服务器地址
        connectionFactory.setPort(5672); // 设置RabbitMQ服务器端口
        connectionFactory.setUsername("guest"); // 设置RabbitMQ用户名
        connectionFactory.setPassword("guest"); // 设置RabbitMQ密码
        return connectionFactory;
    }
}

import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class RabbitMQConnectionManager {

    @Autowired
    private ConnectionFactory connectionFactory;

    public void stopConnection() {
        connectionFactory.destroy();
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class MyController {

    @Autowired
    private RabbitMQConnectionManager connectionManager;

    @GetMapping("/stopRabbitMQConnection")
    public String stopRabbitMQConnection() {
        connectionManager.stopConnection();
        return "RabbitMQ Connection stopped";
    }
}