Micronaut和RabbitMQ
Micronaut和RabbitMQ
提问于 2021-07-02 19:46:15
我正在开发一个使用Micronaut的应用程序，它需要使用RabbitMQ队列中的消息。问题是队列可以提供很多消息，所以我希望有一个参数化的消费者实例数量。
例如，下面的代码自动生成一个消费者实例：
@RabbitListener
public class TestConsumer {
@Queue("TestQueue")
public void handleMessage(String message) {
// some treatment
}
}有没有办法告诉micronaut实例化多个实例？
回答 1
Stack Overflow用户
回答已采纳
发布于 2021-07-30 10:59:23
如果我理解正确的话，您希望配置有多少线程使用队列中的消息。您可以通过在application.yml中配置的执行器来执行此操作
请参阅来自micronaut-rabbitmq docu的以下示例。
@RabbitListener
public class ProductListener {
List<String> messageLengths = Collections.synchronizedList(new ArrayList<>());
@Queue(value = "product", executor = "product-listener")
public void receive(byte[] data) {
messageLengths.add(new String(data));
System.out.println("Java received " + data.length + " bytes from RabbitMQ");
}
}使用application.yml
micronaut:
executors:
product-listener:
type: fixed
nThreads: 25页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/68224628
复制相关文章
相似问题
腾讯云开发者
