ActiveMQ是否有一个反应型客户端库或一种使用spring WebClient获取消息的方法？
我正在使用Spring Webflux和Reactor Netty开发一个NIO SMTP客户端。我需要将消息传递集成到应用程序中，我想知道是否有一种非阻塞的方式来与ActiveMQ交互，我发现的唯一一个在ActiveMQ中提到NIO的文档只讨论了ActiveMQ服务器如何使用NIO模型，而没有讨论使用非阻塞客户机的服务。
共有1个答案
当然，ActiveMQ与任何其他JMS提供程序一样，有一个阻塞API（MessageConsumer.receive（））以及一个设置消息到达后自动调用的MessageListener的方法。由于您使用的是Spring，请看一下这个示例。
此外，您可以使用'NIO'来启用服务器端NIO，而不是tcp前缀：NIO：//hostname：port？key=value，也请参见https://activemq.apache.org/nio-transport-reference，但听起来NIO只在客户机-服务器通信的服务器端实现。
-
我可以检查一个帐户是否是一个广告组的成员，但有没有办法告诉一个帐户是否属于一个OU？我想搜索由你而不是由广告组，我不确定如果这是可能的。下面是我如何搜索一个广告组。
-
假设我有一个接口，它表示我的重置服务，使用
-
我有两个经纪人A和B。如果我想将消息从A转发给B，一切都很简单。我只需要代理中的网络连接器，如下所示： 如果我想从其他队列中使用来自代理 B 的消息，我会犹豫不决（让我们将其命名为 QUEUE。自。消费）我只需要做同样的事情，但双工设置为true，只需听队列。自。在代理 A 上消费，如下所示： 但是它不像我预期的那样工作。似乎每一秒钟只有一条信息被转发，其余的都丢失了。令人惊讶的是，这在代理B队列
-
我想运行一个基于Java的消息代理，将消息路由到Web客户端。Web客户端连接在我们的服务器上使用我们的自定义Javawebsocket代码处理，该代码根据用户数据库对用户进行身份验证。 我认为我的服务器端websocket处理程序代码将连接到ActiveMQ，并通过AQMP执行订阅管理。 但是，我有一个具体要求： 将主题的消息专门路由到一个或多个 Web 客户端 请注意，如果客户端未连接，我不需
-
问题声明：两个不同的代理中有两个队列。每个队列都有一个消费者。生产者正在第一个队列上丢弃消息。我们希望将消息副本发送到第二个队列。为了可视化 经纪人1-- 问题是 < li >每个代理中只创建一个队列。我已经实现了上述4个队列，但寻找更优化的解决方案。 < li >不希望使用任何主题。 < li >只能通过activemq提供的配置来完成。 到目前为止我做了什么：我设法用4个队列完成了上述操作。在