java - MongoDB Java Reactive Streams 生命周期 Micronaut

Question

我正在尝试使用Micronaut 3应用程序实现Java Reactive Streams MongoDB 驱动程序的生命周期事件。

需要使用 执行BeforeInsert()、AfterInsert()、BeforeUpdate()、AfterUpdate()、BeforeDelete()和AfterDelete()生命周期事件com.mongodb.reactivestreams.client.MongoClient。

java驱动程序文档有这样的例子：https ://docs.mongodb.com/drivers/java/sync/current/fundamentals/monitoring/

1. 监控事件
2. 命令事件

但是，本文档没有展示如何使用MongoDB Java Reactive Streams实现生命周期事件。如何实现生命周期事件com.mongodb.reactivestreams.client.MongoClient？

@Singleton
public record Repository(MongoClient mongoClient, MongodbConfiguration mongodbConfiguration) implements IRepository {
    @Override
    public <T> MongoCollection<T> getCollection(String collectionName, Class<T> typeParameterClass) {
        return mongoClient
                .getDatabase(mongodbConfiguration.database())
                .getCollection(collectionName, typeParameterClass);
    }
}

标签： javamongodbmicronautmongodb-javamicronaut-data