I have an application with WebFlux/Coroutines and I need to get and persist all headers from current request (for further audit). Is there a way to put them in CoroutineContext via WebFlux Filter? Any ideas?

message has been deleted

Does spring boot perhaps impose a particular version of kotlin or coroutines?

I am experimenting with Spring Webflux and Kofu. It is working nicely so far, but I was wondering how I could use swagger to generate my api documentation. Is there a way?

When I run

DELETE

operation with

spring-r2dbc

and coroutines, by using such code inside a suspending function:

databaseClient.execute("DELETE FROM tab WHERE field = :field").bind("field", 5).then().awaitFirstOrNull()

Spring Boot gives me the following exception in logs:

2019-09-12 19:52:05,849 [reactor-tcp-epoll-3] ERROR i.r.p.client.ReactorNettyClient - Connection Error
io.netty.util.IllegalReferenceCountException: refCnt: 0
        at io.netty.buffer.AbstractByteBuf.ensureAccessible(AbstractByteBuf.java:1464)
        at io.netty.buffer.CompositeByteBuf.discardReadComponents(CompositeByteBuf.java:1733)
        at io.r2dbc.postgresql.message.backend.BackendMessageEnvelopeDecoder.lambda$apply$0(BackendMessageEnvelopeDecoder.java:69)
        at reactor.core.publisher.FluxCreate.subscribe(FluxCreate.java:94)
        at reactor.core.publisher.Flux.subscribe(Flux.java:8127)

It looks like some kind of resource leak warning, because my code is running fine and SQL statement is executed correctly. If I run:

databaseClient.delete().from("tab").matching(where("field").`is`(5)).then().awaitFirstOrNull()

there is no exception. And there are no problems with other kind of queries (SELECT, INSERT, UPDATE). Is this my bug? Or is this probably a bug in

spring boot

or

spring-r2dbc

?

jackson isn’t recognizing my

@JsonProperty

data class RabbitMqUser(
    @JsonProperty("password_hash")
    val passwordHash: String,
    var tags: String = ""
)

any ideas why that might be?

Hi guys, what is the best practice for Spring Data JPA Entity written in Kotlin, using

data class

or

class

with

lateinit var

, those field in entity mostly don’t have default value

data class is preferable (see data class benefits). and

middleName

should be nullable type

Thanks for all the help and links guys, much appreciated. After all the suggestions and in-depth links, if I understand it correct, the way to go is using the normal

class

with optional

var

properties, for the default

constructor

, take all the mandatory fields first, then the optional fields.

does springmockk allow to mock extension functions? (a bit of a stretch to ask here, as officially spring mockk is not associated with spring)

hello, by any chance anyone knows whether it is possible to specify webflux WebFilter order from Java configuration (i.e. without

@Component

annotation), i.e. equivalent of servlet

FilterRegistrationBean

?

and how do I do in the Explore project to add more modules? currently I’m adding gradle modules manually to the app

This message was deleted.

actually it’s alredy using

spring-xyz-5.2.0.M2

so I guess I have to stick with the 1.2.x version of the

org.jetbrains.kotlinx

libs

the qualifier does not seem to be taken into consideration…

In a

coRouter

context I'd like to use a

TEXT_EVENT_STREAM

like this:

val flux: Flux<String> = loggingThing()
return ok()
            .contentType(MediaType.TEXT_EVENT_STREAM)
            .body(result, String::class.java)

but coRouter expects a

ServerResponse

and not a

Mono<ServerResponse>

.

bodyAndAwait

wouldn't work with

Please specify the element class by using body(Publisher, Class)

. Is such a thing supported out of the box with coRouter DSL or should I return to a standard router here? Using Spring Boot 2.1.6 (and coRouter implementation from 2.2.0-M6 I think)

This message was deleted.

Speaking of R2DBC, I was reading that making JDBC non blocking has insignificant benefits because the databases can only do so much at any given time, so if you have say a pool of 30 threads to do database calls, that is already more operations than the database can do concurrently anyway so making it non blocking will simply save you the overhead of the thread pool. So what is the big deal about nonblocking JDBC ? Anyone disagree?

hello! does anyone know what is the proper way to invoke coroutines from Spring WebFilters? e.g. something like this works and populates the context as expected

class FooFilter : WebFilter {
    override fun filter(exchange: ServerWebExchange, chain: WebFilterChain): Mono<Void> = mono {
        foo()
    }.flatMap { foo ->
        chain.filter(exchange).subscriberContext { it.put("foo", foo) }
    }
    
    suspend fun foo(): Foo { ... }
}

how do you write entities in kotlin? i don't want ti declare any properties that are not nullable from a domain perspective nullable but OTOH also do not have default values for them hence i'd have to declare those variables in the primary constructor. But again this is not possible as spring data needs a parameterless constructor

Hi there! How would I treat (im)mutable collections in my Spring Data (Mongo) entities? I have the following setup

@Document
class Foo(
        test: Set<String>,
        val id: UUID = UUID.randomUUID()
) {

    private val _test: MutableSet<String> = test.toMutableSet()

    val test: Set<String>
        get() = _test

    override fun equals(other: Any?): Boolean {
        if (this === other) return true
        if (javaClass != other?.javaClass) return false

        other as Foo
        return id == other.id
    }

    override fun hashCode(): Int = id.hashCode()
}

@Repository
interface FooRepository : ReactiveCrudRepository<Foo, UUID>

along with the following test

@DataMongoTest
internal class MutableCollectionTest(
        @Autowired private val fooRepository: FooRepository
) {

    @Test
    fun `should save and retrieve Foo`() {
        // Given
        val foo = Foo(setOf("a", "b"))

        // When
        val result = fooRepository.save(foo)
                .then(fooRepository.findById(foo.id))

        // Then
        StepVerifier.create(result)
                .expectNext(foo)
                .verifyComplete()
    }
}

and it fails with:

No property test found on entity class ….Foo to bind constructor parameter to!

This message was deleted.

Is someone using https://github.com/micronaut-projects/micronaut-data ?

I just published SpringMockK 1.1.3. https://github.com/Ninja-Squad/springmockk/releases/tag/1.1.3. It should be available in Maven Central soon. In case you wonder what SpringMockK is, it’s MockBean and SpyBean, but for MockK instead of Mockito.

Will anybody from here be at S1P in Austin next week? Let's say hi to one another!

I'm using Spring Boot 2.2.0.RC1