Micronaut 3.0.2与io.micronaut.rabbitmq:micronaut-rabbitmq相关。我希望使用多个连接，然后使用基于io.micronaut.rabbitmq.connect.ChannelInitializer的建议的io.micronaut.rabbitmq.connect.ChannelInitializermicronaut: name:
浏览 6提问于2021-10-05得票数 0
回答已采纳
它只是说您可以使用以下方法创建一个支持RabbitMQ的项目：但是，一旦这样做了，唯一感兴趣的事情就是生成Application类： Micronaut.run(Application
浏览 0提问于2018-10-27得票数 2
回答已采纳
在micronaut中有没有支持这一点的客户端库？ 就像rabbitmq blow一样。<dependency> <artifactId>micronaut-rabbitmq</artifactId> uri: amqp:&#
浏览 14提问于2019-01-21得票数 0
我得到一个作为Incorrect message body size to deserialize to a Long的序列化异常，因为我知道它不能序列化LONG at io.micronaut.rabbitmq.serdes.JavaLangRabbitMessageSerDes$LongSerDes.deserialize(JavaLangRabbitMessa
浏览 4提问于2021-01-16得票数 1
4回答
: Incorrect message body size to deserialize to a Long at io.micronaut.rabbitmq.serdes.JavaLangRabbitMessageSerDes$LongSerDes.deseriali
浏览 5提问于2021-01-16得票数 6
尝试在Micronaut2.2.1 中实现消费者异常处理如果使用者bean实现了RabbitListenerExceptionHandler，那么异常将被发送到方法实现。@Singletonpublic class RabbitListenerExceptionHandler implements io.micronaut.rabbitmq.exception.RabbitListenerExceptionHandlerif (messageState.isPresent()) {
浏览 2提问于2020-12-11得票数 0
回答已采纳
1回答
我正在使用Micronaut的RabbitMQ包连接到我的RabbitMQ服务器(参见此处：)。我可以轻松地将服务器配置为监听SSL端口，但是我无法理解如何配置我的客户端来通过SSL进行连接。我找到的所有示例都是手动创建连接的，但在我的示例中，这个连接是由Micronaut创建的，我只想通过设置属性来配置它。在中，所有rabbitmq属性都列出了，但是与ssl相关的唯一内容是ssl-context-factory，没有提供解释或示例。我本以为会有类似于的东西，其中(据说)存在一个spring.ra
浏览 7提问于2021-03-24得票数 1
在应用程序开始时，我创建了下面的通道和相关的队列 @Singleton public void initialize(Channel channel) throws IOException {
channel.exchangeDeclare("micronautchannel.queueDeclare("inventory", true, false, false,
浏览 24提问于2021-08-15得票数 0
1回答
我正在开发一个使用Micronaut的应用程序，它需要使用RabbitMQ队列中的消息。问题是队列可以提供很多消息，所以我希望有一个参数化的消费者实例数量。TestQueue") // some treatment } 有没有办法告诉micronaut
浏览 22提问于2021-07-02得票数 0
回答已采纳
将rabbitMQ与Micronaut最新版本配合使用。在消费者上，这两个参数从生产者那里接受相同的值，然而，我从生产者那里发送不同的值。消费者的输出，因为categoryId和id的值相同在生产者端我发送不同的值，如下所示 Maybe<Long> Count(@
浏览 50提问于2021-06-12得票数 0
我目前的工作是：
我正在按照micronaut项目()的指导原则，为一个简单的演示项目实现一个rabbitmq用户。我试图模拟一个服务，它是我的rabbitmq使用者的依赖项。分支test-without-mq的测试将获得成功，因为它没有使用rabbitMQ。这是试图证明问题在于测试RabbitMQ消费者。
浏览 17提问于2022-11-16得票数 7
回答已采纳
我正在开发一个使用RabbitMq和Micronaut(v1.1.3)框架的应用程序，该应用程序的目标是在队列中写入文件的路径。Channel channel) throws IOException { channel.exchangeDeclare("micronaut); ch
浏览 87提问于2019-07-11得票数 2
回答已采纳
1回答
我有一个具有以下结构的Micronaut应用程序现在我想为本地开发和CI/CD中的应用程序执行端到端和集成测试。我正在使用RabbitMq测试容器进行终端和集成测试.合并代码并将应用程序部署到服务器后，运行集成和<
浏览 1提问于2021-08-16得票数 1
我正在尝试使用MongoDb和RabbitMQ测试容器测试Micronaut应用程序。)).withExposedPorts(27017); "
浏览 55提问于2021-08-15得票数 0
尝试用JUnit 5作微卫星兔实验容器，但Error disposing of bean registration [io.micronaut.rabbitmq.intercept.RabbitMQConsumerAdviceValue");}ERROR i.m.context.DefaultBeanContext - Error disposing of bean registration [io.micronaut.rabbitmq.intercept.RabbitMQConsumerA
浏览 6提问于2021-01-09得票数 0
回答已采纳
1回答
反应堆流量返回误差无限
、、、、
我已经将Micronaut应用程序从2.5.XX更新到3.0.0。根据Micronaut文档，项目反应堆是用于反应性编程的推荐反应库。我已经整合了rabbitMQ和rabbitMQ生产商的关机。iProductManager.findFreeText(text)抛出一个异常，因为rabbitMQ生产者没有运行。
浏览 1提问于2021-08-26得票数 0
1回答
我目前正在使用Micronaut和gRPC编写一个新的应用程序。在部署方面，我计划在Kubernetes集群上运行它，这意味着我希望启用管理端点(用于活跃性探测等)。false enabled: true我的build.gradle文件看起来是这样的：为了让它正常工作，我还缺少什么？
浏览 20提问于2021-05-17得票数 0
我想连接到一个单独的micronaut应用程序，它运行良好，并正确连接到本地领事。:inject-java:1.0.0.M1'compile 'io.micronaut:spring::120) at io.mic
浏览 16提问于2019-05-03得票数 0
回答已采纳
这很简单，为此，我使用了micronaut<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://>3.3.4</micronaut.version>
<exec.mainClass>com.autentia.Application</exec.mainClass><mi
浏览 8提问于2022-03-09得票数 0
回答已采纳
云服务器
对象存储
ICP备案
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号