java - RabbitMQ 监听器自动停止

Question

我正在使用基于 spring rabbit mq 模板的侦听器

在负载增加的情况下，监听器只是简单地关闭

如何防止监听器关闭？

或者如何在关闭后立即重新启动监听器？

我正在使用以下配置：

<rabbit:connection-factory id="connectionFactory" host="localhost" password="guest" port="5672" username="guest" />

<rabbit:template id="amqpTemplate" connection-factory="connectionFactory"
                 exchange="${amqp_exchange_name}"/>

<rabbit:admin connection-factory="connectionFactory"/>

<rabbit:queue name="${amqp_queue_name}"/>

<rabbit:listener-container connection-factory="connectionFactory" concurrency="5">
    <rabbit:listener ref="joblistener" queue-names="${amqp_queue_name}"/>
</rabbit:listener-container>

<bean id="joblistener" class="com.org.sample.Consumer"/>

消费者是我的听众，其中包含以下功能

@Override
public void onMessage(Message message) {
      //do something
}