我想使用micronaut-rabbitmq通过主题在服务之间发送消息。因此，我在ChannelInitializer中创建了一个交换、队列和绑定，如下所示： channel.exchangeDeclare("registration", BuiltinExchangeType.TOPIC@Binding("user.new")
override fun userCreated(event: UserCreatedEvent) 我希望，由于
浏览 8提问于2020-09-07得票数 0
回答已采纳
", BuiltinExchangeType.DIRECT, true);
channel.queueBind("inventory", "micronaut", "books.inventory");
}
} 我想要编写JUn
浏览 24提问于2021-08-15得票数 0
我正在开发一个使用RabbitMq和Micronaut(v1.1.3)框架的应用程序，该应用程序的目标是在队列中写入文件的路径。工作进程(RabbitListeners)使用队列并对指定的文件执行某些操作。这些操作可能很繁重，因此我不希望队列立即将消息分配给第一个可用的工作进程，以避免工作进程过载。Channel channel) throws IOException { channel.exchangeDeclare("micro
浏览 87提问于2019-07-11得票数 2
回答已采纳
1回答
我正在使用Micronaut的RabbitMQ包连接到我的RabbitMQ服务器(参见此处：)。我可以轻松地将服务器配置为监听SSL端口，但是我无法理解如何配置我的客户端来通过SSL进行连接。我找到的所有示例都是手动创建连接的，但在我的示例中，这个连接是由Micronaut创建的，我只想通过设置属性来配置它。我本以为会有类似于的东西，其中(据说)存在一个spring.rabbitmq.ssl.enabled属性来打开
浏览 7提问于2021-03-24得票数 1
我想使用artemis作为消息代理。在micronaut中有没有支持这一点的客户端库？ 就像rabbitmq blow一样。<dependency> <artifactId>micronaut-rabbitmq</artifactId>
</dependency>
浏览 14提问于2019-01-21得票数 0
1.0.0刚刚发布(2018-10-25年)，在其中似乎没有说明如何实际使用或发布消息。它只是说您可以使用以下方法创建一个支持RabbitMQ的项目：但是，一旦这样做了，唯一感兴趣的事情就是生成Application类：
public stati
浏览 0提问于2018-10-27得票数 2
回答已采纳
尝试在Micronaut2.2.1 中实现消费者异常处理如果使用者bean实现了RabbitListenerExceptionHandler，那么异常将被发送到方法实现。如果使用者bean没有实现RabbitListenerExceptionHandler，那么异常将被路由到主异常处理程序bean。@Singletonpublic class RabbitListenerExceptionHandler implements io.micronaut.rabbitmq.ex
浏览 2提问于2020-12-11得票数 0
回答已采纳
1回答
我使用Spring、Spring、STOMP作为我的应用程序，RabbitMQ作为代理。我需要记录通过RabbitMQ到Postgresql表的所有消息。我知道我可以在Spring中编写@MessageMapping并在那里登录，但我的问题是，一些客户端通过MQTT协议直接与RabbitMQ对话，而Spring还不支持它()。此外，浏览器客户端使用STOMP协议通过Spring与RabbitMQ进行
浏览 4提问于2015-05-21得票数 6
回答已采纳
1回答
我正在开发一个使用Micronaut的应用程序，它需要使用RabbitMQ队列中的消息。问题是队列可以提供很多消息，所以我希望有一个参数化的消费者实例数量。TestQueue") // some treatment } 有没有办法告诉micronaut
浏览 22提问于2021-07-02得票数 0
回答已采纳
我有一个从队列读取RabbitMQ消息的Apache Apex应用程序DAG。我应该使用哪个Apache Apex Malhar运算符？有几个运算符，但不清楚使用哪个运算符以及如何使用它。
浏览 1提问于2017-02-13得票数 2
是否可以使用RabbitMQ STOMP客户端将单个队列绑定到多个主题？每次发送订阅框架服务器的客户端为它创建一个新的队列时，它使"prefetch-count“的使用对我来说无用，因为它单独应用于每个订阅。我只是在寻找通过RabbitMQ Web-STOMP在单个队列中获取具有多个主题的消息的任何方法。有什么想法吗？
浏览 0提问于2012-12-12得票数 4
回答已采纳
我正在用Micronaut建立几个微型服务。服务的一个要求是它们都必须生成事件，但是任何服务都可以选择侦听其他服务的事件。我希望构建这个程序，以便在本地插入RabbitMQ，但在任何环境中运行时都可以使用PaaS代理。 start(); subscriber.receive();}
订阅的RabbitMQ'e60dc206-f757
浏览 10提问于2021-10-19得票数 0
下面是我的代码：import com.rabbitmq.client.Channel;import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;amqp-client-4.0.2.jar;sl
浏览 14提问于2017-08-11得票数 0
回答已采纳
我有一个使用RabbitMQ的Java应用程序。此应用程序创建主题交换，并使用自己的路由键将消息推送到主题。这样，如果我想要任何应用程序的数据，我就创建一个队列绑定到exchange主题和我想要的路由密钥。我想通过使用一个具有Qpid JMS作为客户端和ActiveMQ作为服务器的Java应用程序来做同样的事情。信息显示这是可能的，但我不知道怎么做。在RabbitMQ看来，我找不到一个具体的例子。我可以创建队列，但是
浏览 5提问于2020-02-19得票数 2
回答已采纳
我在下面提到的代码中获取httpClient的NullPointerException： @Introspected @Clie
浏览 46提问于2021-04-15得票数 1
我知道已经有很多关于RabbitMQ的帖子，如果它合适或者不使用它，而不是XMPP，等等。但是既然RabbitMQ是强制性的，那么我应该如何在我的场景中使用RabbitMQ呢？当客户端断开连接时，有两种可能的实现: 1)无法读取先前的消息；2)他可以在登录前5分钟收到消息
现在，给出这个规范，使用RabbitMQ的最佳实践是什么？RabbitMQ给出了什么已经实
浏览 1提问于2015-06-22得票数 1
如何使用Micronaut客户端注释映射errorType，在编程情况下，我们可以在成功和失败的情况下提供body类型和errorType对象。以编程方式调用客户端：import io.micronaut.http.HttpRequest;
import io.micronaut.http.HttpResponse} catch (HttpClientResponseEx
浏览 0提问于2019-09-16得票数 0
回答已采纳
1回答
在这里，我将解释我想要的用例：
然后使用MQTT客户端设置client="client1“，使用相同的交换连接到"topic1”(amp.topic)。
浏览 1提问于2020-10-29得票数 1
回答已采纳
我想通过内置的micronaut发现客户端在我的micronaut应用程序中使用来自亚马逊网络服务参数存储的属性，但是在提到'rootHierarchyPath‘之后，没有适当的文档说明如何配置和注入各个参数下面是application.yml代码，我提到了根路径，但找不到如何获取存储在参数存储中的条目'dbUserName‘和'dbPassword’。
浏览 22提问于2019-03-30得票数 1
有没有办法用micronaut，kafka和kotlin做到这一点？谢谢。
浏览 6提问于2020-03-26得票数 0
云服务器
ICP备案
对象存储
云点播
实时音视频
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号