Junit 5 功能测试 Micronaut 消息驱动的应用程序
Junit 5 functional testing the Micronaut Messaging-Driven Application
我有一个 Rabbit MQ Micronaut 消息驱动应用程序。该应用程序仅包含消费者端,生产者端在另一个 REST API 应用程序上。
现在我只想在消费者端执行 JUnit 5 测试。尝试获得测试仅包含 Rabbit MQ Listener 的消息驱动应用程序的最佳想法
@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
进行集成测试,在我的例子中,生产者和接收者在不同的服务器上。那么我需要在测试环境中为每个 RabbitListener
创建 RabbitClient
还是有什么方法可以模拟 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 消息驱动应用程序功能测试的最佳方法是什么?在这个问题中,我在另一个应用程序上有一个生产者。所以我无法注入 PRODUCER 客户端。如何在 LISTENER 端测试此功能?
使用@RabbitClient
创建生产者或直接使用javaapi
我有一个 Rabbit MQ Micronaut 消息驱动应用程序。该应用程序仅包含消费者端,生产者端在另一个 REST API 应用程序上。
现在我只想在消费者端执行 JUnit 5 测试。尝试获得测试仅包含 Rabbit MQ Listener 的消息驱动应用程序的最佳想法
@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
进行集成测试,在我的例子中,生产者和接收者在不同的服务器上。那么我需要在测试环境中为每个 RabbitListener
创建 RabbitClient
还是有什么方法可以模拟 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 消息驱动应用程序功能测试的最佳方法是什么?在这个问题中,我在另一个应用程序上有一个生产者。所以我无法注入 PRODUCER 客户端。如何在 LISTENER 端测试此功能?
使用@RabbitClient
创建生产者或直接使用javaapi