@Repository

ReactiveMongoTemplate

fun beans() = beans {
    bean {
        val databaseName = "person"
        val databaseString = "<mongodb://localhost:27017>"
        val mongoClient: MongoClient = MongoClients
                .create("$databaseString/$databaseName")

        ReactiveMongoTemplate(mongoClient, databaseName)
    }
}

class PersonHandler(private val repository: ReactiveMongoTemplate)

ReactiveMongoTemplate

ReactiveFluentMongoOperations

class EventRepository(private val mongo: ReactiveFluentMongoOperations) {

    fun count() = mongo.query<Event>().count()

    fun findAll() = mongo.query<Event>().all()

    fun findOne(id: String) = mongo.query<Event>().matching(Query(Criteria("firstname").isEqualTo("luke"))).one()

    fun deleteAll() = mongo.remove<Event>().all()

}

AbstractMongoConfiguration

ReactiveFluentMongoOperations

beans {}

registerBean {
    val connectionString = ConnectionString("<mongodb://localhost:27017/person>")
    val factory = SimpleReactiveMongoDatabaseFactory(connectionString)

    ReactiveMongoTemplate(factory)
}

@Configuration

@SpringBootApplication

Application context not configured for this file

@Configuration

@Configuration

> Task :backend:bootRun
Error: Main method is not static in class kudos.ApplicationConfig, please define the main method as:
   public static void main(String[] args)

fun main(args: Array<String>) = SpringApplication.run(ApplicationConfig::class.java, *args)

@JVMStatic
fun main(args: Array<String>) {
            SpringApplication.run(ApplicationConfig::class.java, *args)
}

class PersonRepositoryIntegrationTest {

    private val databaseString = ConnectionString("<mongodb://localhost:27017/personTest>")

    private val databaseFactory = SimpleReactiveMongoDatabaseFactory(databaseString)

    private val mongo = ReactiveMongoTemplate(databaseFactory)

    @test
    fun `Should persist two persons`() {
        val personToPersist = listOf(
                Person("Burce Lee"),
                Person("Jackie Chan"))

        mongo.insertAll(personToPersist).blockLast() // throws NullPointerException

        assertTrue { true }
    }
}

src/
    main/
        kotlin/
            Person.kt
    test/
        kotlin/
            PersonRepositoryIntegrationTest.kt