NonPauseableSqsConfig.java

@Configuration
@Slf4j
public class NonPauseableSqsConfig {

    @Bean
    static BeanPostProcessor nonPauseableListenerContainerRegistryPostProcessor() {
        return new BeanPostProcessor() {
            @Override
            public Object postProcessAfterInitialization(Object bean, String beanName) {
                if (bean instanceof DefaultListenerContainerRegistry registry) {
                    return new NonPauseableListenerContainerRegistry(registry);
                }
                return bean;
            }
        };
    }

    static class NonPauseableListenerContainerRegistry implements MessageListenerContainerRegistry, SmartLifecycle {

        private final DefaultListenerContainerRegistry delegate;

        NonPauseableListenerContainerRegistry(DefaultListenerContainerRegistry delegate) {
            this.delegate = delegate;
        }

        @Override
        public boolean isPauseable() {
            return false; // This is the key!
        }

        // Delegate SmartLifecycle methods
        @Override
        public void start() {
            delegate.start();
        }

        @Override
        public void stop() {
            delegate.stop();
        }

        @Override
        public void stop(Runnable callback) {
            delegate.stop(callback);
        }

        @Override
        public boolean isRunning() {
            return delegate.isRunning();
        }

        @Override
        public int getPhase() {
            return delegate.getPhase();
        }

        @Override
        public boolean isAutoStartup() {
            return delegate.isAutoStartup();
        }

        @Override
        public void registerListenerContainer(MessageListenerContainer<?> listenerContainer) {
            delegate.registerListenerContainer(listenerContainer);
        }

        // Delegate MessageListenerContainerRegistry methods
        @Override
        public Collection<MessageListenerContainer<?>> getListenerContainers() {
            return delegate.getListenerContainers();
        }

        @Override
        public MessageListenerContainer<?> getContainerById(String id) {
            return delegate.getContainerById(id);
        }
    }
}