我有一个rabbit mq micronaut消息驱动的应用程序。应用程序只包含使用者端，生产者端在另一个restapi应用程序上。
现在我只想对使用者端执行junit5测试。尝试获得测试仅包含rabbitmq侦听器的消息驱动应用程序的最佳想法

@RabbitListener
public record CategoryListener(IRepository repository) {

@Queue(ConstantValues.ADD_CATEGORY)
    public CategoryViewModel Create(CategoryViewModel model) {
        LOG.info(String.format("Listener --> Adding the product to the product collection"));
        Category category = new Category(model.name(), model.description());
        return Single.fromPublisher(this.repository.getCollection(ConstantValues.PRODUCT_CATEGORY_COLLECTION_NAME, Category.class)
                .insertOne(category)).map(success->{
            return new CategoryViewModel(
                    success.getInsertedId().asObjectId().getValue().toString(),
                    category.getName(),
                    category.getDescription());
        }).blockingGet();
    }
}

经过研究，我发现我们可以使用 Testcontainers 对于集成测试，在我的例子中，生产者和接收者在不同的服务器上。所以我需要创造 RabbitClient 对于每个 RabbitListener 在测试环境中或者有什么方法可以模拟 RabbitClient ```
@MicronautTest
@Testcontainers
public class CategoryListenerTest {

@Container
private static final RabbitMQContainer RABBIT_MQ_CONTAINER = new RabbitMQContainer("rabbitmq")
        .withExposedPorts(5672, 15672);

@Test
@DisplayName("Rabbit MQ container should be running")
void rabbitMqContainerShouldBeRunning() {
    Assertions.assertTrue(RABBIT_MQ_CONTAINER.isRunning());
}

}

对micronaut消息驱动的应用程序执行功能测试的最佳方法是什么？在这个问题上，我有另一个应用程序的生产者。所以我不能给制作人客户注射。如何在侦听器端测试此函数？