RabbitMQ - Graceful shutdown - Configure Shutdown timeout in rabbitmq #helpdev-blog

RabbitmqConnectionConfig.java

import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitmqConnectionConfig {
  
   @Value("${spring.rabbitmq.shutdown-timeout:60000}")
   private Integer shutdownTimeout;
  
   @Bean
   public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(final ConnectionFactory connectionFactory,
         final SimpleRabbitListenerContainerFactoryConfigurer configurer) {
      SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory();
      configurer.configure(factory, connectionFactory);
      factory.setContainerCustomizer(c -> c.setShutdownTimeout(shutdownTimeout));
      return factory;
   }
  
}