我使用Mule ESB来设计一个过程,通过这个过程可以向一个主题发布消息。订阅者将收听主题并接收消息。每个用户对消息的反应不同。这里的目标是能够从HTTP向主题发送测试消息,以测试订阅者。 下面是如何配置JMS连接: 这是流程: 当我运行测试时,我得到以下错误: 任何建议将不胜感激。 罗斯
我需要为ActiveMQ创建一个主题和一个持久订阅者,我的问题是我不知道在哪里指定它。我可以创建主题并使用消息,但是当我关闭订阅者然后继续发送消息并再次打开订阅者时,它不会读取它们。 这是我目前掌握的情况: 发送消息: 接收消息: 我已经阅读了这篇文章,我明白我需要创建持久订阅者。 我也读过spring文档 我认为它与(我没有实现,我使用的是默认配置)有关,文档显示: 但是我似乎找不到在哪里创建持
我刚刚开始使用activemq,我有一个关于追溯消费者的问题,为了启用此功能,您需要有一个持久的订阅。但是,在主题上启用和不启用追溯的持久订阅有什么区别?活跃的mq文档说。 http://activemq.apache.org/retroactive-consumer.html 追溯性使用者只是一个普通的 JMS Topic 使用者,它指示在订阅开始时,每次尝试都应该用于返回时间并发送使用者可能错
我在这里对如何正确使用ActiveMQ有点困惑。 我想做的是 系统A向虚拟主题发送消息。然后系统B和C都使用来自同一虚拟主题的消息。系统B或C可能会脱机。所以当它们重新联机时,我需要它们接收脱机期间产生的所有消息。 到目前为止我所尝试的 我读过关于持久订阅者(http://activemq.apache.org/how-do-durable-queues-and-topics-work.html
我们有一个ActiveMQ代理,它使用JMS、AMQP和MQTT从非常不同的客户端连接到。出于某种原因,我们还没有弄清楚一组特定的MQTT客户端经常(不总是)持久订阅。这是一个测试环境,客户端经常被添加和删除,后者有时通过拔掉插头或重新启动嵌入式设备,因此它们无法正确取消订阅。效果(IIUC)是代理为可能再也见不到的设备堆积“离线持久订阅”(我可以在超文本传输协议下看到这些),永远保留关于这些主题
我想运行一个基于Java的消息代理,将消息路由到Web客户端。Web客户端连接在我们的服务器上使用我们的自定义Javawebsocket代码处理,该代码根据用户数据库对用户进行身份验证。 我认为我的服务器端websocket处理程序代码将连接到ActiveMQ,并通过AQMP执行订阅管理。 但是,我有一个具体要求: 将主题的消息专门路由到一个或多个 Web 客户端 请注意,如果客户端未连接,我不需
我正在尝试编写一个基本的 ActiveMQ 客户端来侦听一个主题。我正在使用Spring启动活动MQ。我有一个基于各种教程构建的实现,它使用默认Jms列表容器工厂,但是我在使其正常工作时遇到了一些问题。 一切都很好,直到我尝试获得一个持久的订阅。当我这样做时,我发现在容器工厂中设置了客户机id,我得到了一个关于如何在共享连接上设置客户机id的错误。 <code>原因:共享连接的代理不支持setCl
我正在使用JMS消费来自ActiveMQ Artemis主题的消息。我的消费者直接连接到他们消费者队列的FQQN。像这样: 而中的配置是: 但是,DLQ的名字将会是<代号> DLQ。Transactions.Client1,没有消费者名称。 我需要的是每个消费者都有自己的DLQ。像这样的东西。这可能吗? 编辑: 我说的“消费者”,可能(实际上)更像是一个“消费群体”。例如,< code>Consu
我最近不得不从ActiveMQ 5.X切换到我正在进行的项目的ActiveMQ Artemis。我有一个函数可以读取可用主题并填充MySQL数据库中的表,但该函数不再适用于Artemis中方法的更改。 基本上,我不需要获得可用主题的列表(也称为多播队列),而是需要获得可用地址的列表,以便我的消费者可以连接并为该地址创建一个同名的多播队列。 以下是我需要此功能的原因: < li >用户使用网站(从数
我有一个用例,我想在一个应用程序中创建多个监听器(6)。我想订阅多个目的地(6个主题)。所有订阅都是持久的。我为每个监听器使用单独的默认消息监听器容器(DMLC),并使用不同的客户端id,但我对如何使用连接工厂感到困惑。 我是否应该使用单个 ActiveMQ 池连接工厂,最大连接数指定为 6。或者我应该为每个侦听器使用不同的池连接工厂吗? 使用具有最大连接池连接工厂对于持久用户有什么危害吗? 源代
我们正在运行活动 MQ 5.6.0。在我们的测试环境中,我们有 3 个代理在静态网络中运行。下面是当前方案。我们有6个消费者随机连接到3个经纪人。一个经纪人有3个消费者,第二个有2个,第三个有1个。当我们向队列堆积消息时,我们看到消息积压在第三个代理上,有 1 个使用者,另外两个代理没有获得任何积压,其余 5 个使用者处于空闲状态。 在下面,您将找到我们所有一个代理(dev.queue01)的配置
我在完整图形拓扑上有一个代理网络,在不同服务器上有3个节点:A,B和C。每个代理都附加了一个生产者,并且出于测试目的,在代理 C 上只有一个非代理使用者。由于我使用的是完整图拓扑,因此每个代理还为其他每个节点都有一个代理使用者。 问题是:A收到一些消息。我希望它将这些消息转发给代理C,该代理连接了一个“真实”消费者。这不会发生,代理A存储这些消息,直到一个“真实”消费者连接到它。 我的配置(或理解
我使用网络连接器配置了两个代理 A 和 B。如果我使用独占使用者(单个使用者)或消息组(JMXgroupID),消息顺序是否保留? 在经纪人文档的网络中,我发现: 代理网络不会保留总消息排序。总排序适用于单个使用者,但网络桥引入第二个使用者。此外,网络桥接使用者通过 producer.send(..) 转发消息,因此它们从转发代理上的队列头转到目标上队列的尾部。如果单个使用者在联网代理之间移动,则
我试图只通过SSL配置Apache ActiveMQ 5.10.0,并在Windows7上测试身份验证和授权。在activemq.xml文件中,我有 在启动经纪人时,我收到了消息。 在其他cmd中,我正在启动我的java spring项目jar……我得到以下日志: 现在,即使我为“系统”提供了不正确的密码或评论以下行 但它仍在与经纪人建立联系。我的身份验证和授权是否未正确完成?
我对活跃的MQ有点陌生,所以请容忍我。 我正在尝试为我的一些 Java 和 CPP 应用程序利用 ActiveMQ 优先级备份功能。我在两个不同的服务器(本地和远程)上有两个代理,我希望我的应用程序具有以下行为。 < li >启动时总是连接到本地代理 < li >如果本地代理关闭,请连接到远程代理 < li >连接到远程时,如果本地恢复,我们将重新连接到本地。 我已经成功地在java应用程序上测试