问题：

在运行同时发布事件的多个集成测试后，InMemoryConnector.clear（）不起作用。

我的实现

@TestInstance(TestInstance.Lifecycle.PER_CLASS)
@QuarkusTest
@QuarkusTestResource(
    value = InMemReactiveMessagingLifecycleManager::class, initArgs = [
        ResourceArg(value = "incoming", name = "example-processed"),
        ResourceArg(value = "outgoing", name = "example")
    ]
)
class DemoEventProducerTest {

    @Inject
    lateinit var demoEventProducer: demoEventProducer

    @Inject
    @Any
    lateinit var inMemoryConnector: InMemoryConnector

    @Inject
    lateinit var testHelper: TestHelper

    @Test
    fun `publishEvent - valid action - event published`() {
        demoEventProducer.publish()

        val eventQueue = inMemoryConnector.sink<String>("example")
        //event queue contains other events that has been published


      
    }
}

个字符

预期行为：

val eventQueue = inMemoryConnector.sink<String>("example")

型
我想在这个测试运行之前清理队列，这样我就只会有这个测试产生的一个事件。
我尝试使用@BeforeEach @ AfterEach，以便在执行测试方法之前，我希望队列被清理。但它不起作用。