【RabbitMQ】手动开关监听_rabbitlistenerendpointregistry.start();

一、@RabbitListener关闭自动监听

@RabbitListener(id = "xxx"
        , bindings = @QueueBinding(value = @Queue(value = "queueNameXXX", autoDelete="true/false")
        , exchange = @Exchange(value="exchangeXXX")
        , key = "routeKeyXXX")
        // 关闭自动监听
        , autoStartup = "false"
)
1
2
3
4
5
6
7

二、RabbitMQ手动开关监听

    @Autowired
    private RabbitListenerEndpointRegistry rabbitListenerEndpointRegistry;

    @Autowired
    private CachingConnectionFactory cachingConnectionFactory;

    public void start(){
        // 开启监听
        rabbitListenerEndpointRegistry.start();
    }

    public void stop(){
        // 关闭监听
        rabbitListenerEndpointRegistry.stop();
        cachingConnectionFactory.resetConnection();
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16