DemoApplicationTests.kt

package com.example.demo

import org.junit.jupiter.api.Test
import org.slf4j.Logger
import org.slf4j.LoggerFactory
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.beans.factory.annotation.Qualifier
import org.springframework.boot.test.context.SpringBootTest
import org.springframework.integration.channel.QueueChannel
import org.springframework.integration.test.context.SpringIntegrationTest
import org.springframework.messaging.Message
import org.springframework.messaging.MessageChannel
import org.springframework.messaging.support.ChannelInterceptor


@SpringBootTest
@SpringIntegrationTest

class DemoApplicationTests constructor(
    @Autowired val myGateway: MyGateway,
    @Autowired @Qualifier("finalOutputActivator") val finalQueueChannel: QueueChannel,
    @Autowired @Qualifier("updateModelData") val workerQueueChannel: QueueChannel,
) {


    val logger: Logger = LoggerFactory.getLogger(this::class.java)

    @Test
    fun `test poller`() {

        val myModels =
            listOf(
                MyModel(1, null),
                MyModel(2, "Hello"),
                MyModel(3, "World")
            )

        workerQueueChannel.addInterceptor(object : ChannelInterceptor {
            override fun postReceive(message: Message<*>, channel: MessageChannel): Message<*>? {
                logger.info("Received message ${message.payload}")
                return super.postReceive(message, channel)
            }
        })

        myGateway.updateModels(myModels, 1)


        finalQueueChannel.receive(15_000)
    }

}