When The Context Closes

To invoke a method when the context is closed, use the javax.annotation.PreDestroy annotation:

import jakarta.annotation.PreDestroy; (1)
import jakarta.inject.Singleton;
import java.util.concurrent.atomic.AtomicBoolean;
@Singleton
public class PreDestroyBean implements AutoCloseable {
    AtomicBoolean stopped = new AtomicBoolean(false);
    @PreDestroy (2)
    @Override
    public void close() throws Exception {
        stopped.compareAndSet(false, true);
    }
}

import jakarta.annotation.PreDestroy (1)
import jakarta.inject.Singleton
import java.util.concurrent.atomic.AtomicBoolean
@Singleton
class PreDestroyBean implements AutoCloseable {
    AtomicBoolean stopped = new AtomicBoolean(false)
    @PreDestroy (2)
    @Override
    void close() throws Exception {
        stopped.compareAndSet(false, true)
    }
}

import jakarta.annotation.PreDestroy (1)
import jakarta.inject.Singleton
import java.util.concurrent.atomic.AtomicBoolean
@Singleton
class PreDestroyBean : AutoCloseable {
    internal var stopped = AtomicBoolean(false)
    @PreDestroy (2)
    @Throws(Exception::class)
    override fun close() {
        stopped.compareAndSet(false, true)
    }
}

For factory beans, the preDestroy value in the Bean annotation tells Micronaut which method to invoke.

import io.micronaut.context.annotation.Bean;
import io.micronaut.context.annotation.Factory;
import jakarta.inject.Singleton;
@Factory
public class ConnectionFactory {
    @Bean(preDestroy = "stop") (1)
    @Singleton
    public Connection connection() {
        return new Connection();
    }
}

import io.micronaut.context.annotation.Bean
import io.micronaut.context.annotation.Factory
import jakarta.inject.Singleton
@Factory
class ConnectionFactory {
    @Bean(preDestroy = "stop") (1)
    @Singleton
    Connection connection() {
        new Connection()
    }
}

import io.micronaut.context.annotation.Bean
import io.micronaut.context.annotation.Factory
import jakarta.inject.Singleton
@Factory
class ConnectionFactory {
    @Bean(preDestroy = "stop") (1)
    @Singleton
    fun connection(): Connection {
        return Connection()
    }
}

import java.util.concurrent.atomic.AtomicBoolean;
public class Connection {
    AtomicBoolean stopped = new AtomicBoolean(false);
    public void stop() { (2)
        stopped.compareAndSet(false, true);
    }
}

import java.util.concurrent.atomic.AtomicBoolean
class Connection {
    AtomicBoolean stopped = new AtomicBoolean(false)
    void stop() { (2)
        stopped.compareAndSet(false, true)
    }
}

import java.util.concurrent.atomic.AtomicBoolean
class Connection {
    internal var stopped = AtomicBoolean(false)
    fun stop() { (2)
        stopped.compareAndSet(false, true)
    }
}