我有一个由3个经纪人组成的网络，但有时经纪人会以一种非常独特和恼人的方式失败 它们仍然接受连接，但在其他情况下停止与客户机通信（即使是那些仍然连接的客户机）。 对于用java创建的新连接，这意味着： con = factory.getConnection(); // method returns, connection is created con.createSession(false, Session.AUTO_ACKNOWLEDGE); // never returns 在服务器端，在调

清除队列（不是主题）的消息后，活动MQ管理控制台中此队列的挂起消息编号更改为负值 我假设任何队列的挂起消息数都应该为正。这是净化的问题吗？还是activemq的一个bug 这似乎是ActiveMQ中的一个bug。在清除队列时，我曾多次亲眼目睹此错误。然而，它似乎并不影响实际的消息传递 ActiveMQ问题跟踪器中有许多与此问题相关的未决问题。如果您愿意，您可以投票支持他们： 清除不会停止mq处理排队作业。重新启动ActiveMQ只是为了摆脱现有的作业。缺点是，这将使所有数字重置为默认值 这个问

我正在本地计算机上运行ActiveMQ 5.9.0版本，用于开发目的（Windows 7）。我使用AMQP作为协议，使用ApacheQPID作为客户端来使用来自activeMQ代理（AMQP1.0协议）的消息（发布-订阅） 尽管我在activemq.xml中注释掉了除amqp之外的所有协议，但我仍然定期在代理日志（标准输出）中看到以下消息： 警告：传输连接到tcp://失败：java.net.SocketException:连接重置 我确实尝试在activemq.xml中“取消注释”openw

我刚接触JEE7，一直在做一些快速练习，但我遇到了一个问题。我有一个示例JavaSE应用程序，它向ActiveMQ队列发送消息，我在Wildfly 8上部署了一个MDB，它在消息传入时读取消息。这一切都很好，我可以使用getText接收消息。但是，当我使用getBody获取消息体时，我会得到一个“未知错误”。有人能告诉我我做错了什么吗 下面是我的代码 /***CLIENT CODE****/ import javax.jms.*; import org.apache.active

我试图在ActiveMQ（5.11.1）中查看队列中的所有消息。为此，我使用了Hawtio（1.4.51）。ActiveMQ中的我的队列包含790消息 我的步骤到现在为止： 默认情况下，hawtio在ActiveMQ队列中最多显示400条消息。因此，我转到我的broker.xml设置并添加： 因此，经过更多的调查，并在本博客的帮助下： 我能够找到允许Hawtion中的ActiveMQ显示500多个条目的设置。设置位于此处： 在hawtio应用程序的右侧，有一个带有小箭头的用户图片。按此按钮并

在ActiveMQ中，是否可以在特定时间间隔后自动将消息从一个主题转发到另一个主题。是否可以添加更多详细信息？你已经试过一些代码了吗？嗨，皮耶罗，谢谢你的回复。我有一个简单的制作人和一个消费者，他们从主题“示例”中消费信息，信息被很好地消费了。在处理过程中，如果发生任何异常，消息将自动发送到另一个主题“sampleErrorTopic”。我想有一个机制，将自动转发这些消息（从主题“sampleErrorTopic”）到第三个主题“SamplePlay”，10分钟后。希望这将清除您的用例。为发送到

如中所述，我们有一个由不同服务器上的三个代理组成的代理网络。 网络连接器的配置如下所示： <networkConnectors> <networkConnector uri="static:(ssl://broker2:61616,ssl://broker3:61616)" networkTTL="5"/> </networkConnectors> 然而，这样做也很可怕，因为我们觉得我们没有

我是activeMQ的新手。我想制作一个简单的应用程序，其中一个EJB3向ActiveMQ发送一条消息，并在MessageDrivenBean中接收和检索该消息。这样做的可能性有很多。我对这么多的例子感到困惑。任何人都可以指出创建此类应用程序的好链接。我想使用ActiveMQ5.5.1和JBoss6.0.0。这种组合的已知问题是什么。 任何帮助都将不胜感激 谢谢您应该从一些Fuse网络研讨会/教程开始 此外，这里还有一个集成AMQ/JBoss的指南 本书的第一章是免费的，并提供了一个很好的快速

我在处理Camel事务时遇到了麻烦，在Camel列表提供了一些帮助之后，我最终在id为“activemq”的bean中使用org.apache.activemq.Camel.component.ActiveMQComponent。如果我使用'activemqTx'的id，它就可以工作。但我似乎找不到任何关于“activemqTx”作为bean id的意义的文档 只有一条消息通过此路由： <bean id="activemq" class="org.apache.activemq.camel

我正在进行一个概念验证项目，旨在探索将工作从NIO服务器转移到后端处理的消息队列的好处。我将Grizzly用于NIO样板文件，将Spring集成用于消息传递（使用JMS/ActiveMQ作为消息传递实现）。基本上，我想做的是： 客户端连接->服务器->服务器创建“要完成的工作”消息->JMS/ActiveMQ 在ActiveMQ消息队列上，许多“工作者”将积极地使用这些消息，处理它们，并将结果放在另一个队列上。服务器正在侦听该队列上的“响应消息”，一旦收到消息，它将执行以下操作： 响应队列->服

我有两个ActiveMQ代理（A和B），它们被配置为存储转发网络。当有一个消费者连接到代理B上并且生产者向A发送消息时，它们可以完美地将消息从A转发到B。问题是，当消费者被终止并重新连接到A时，B上排队的消息（它们从A转发）不会转发回消费者连接到的A。即使我向B发送新消息，在我重新启动代理之前，所有消息都被卡在B上。我已尝试在代理网络连接器上设置networkTTL=“4”和duplex=“true”，但它不起作用。能否提供有关代理A和B配置的更多信息，以及您试图实现的目标 在我看来，你可以通过

我在部署功能时遇到了问题。该特性包含三个bundle，Karaf很好地部署了这些bundle，但是当部署它们时，ActiveMQ开始出现问题 部署的捆绑包是简单的。“复杂”是一个驼峰路由，它公开一个CXF端点并调用一个端点模拟。我刚把.kar，那个kar的拉链和我的引信日志贴在后面。服务正在运行，但activeMQ的问题始终存在 错误总是相同的： 2013-05-14 15:19:48,046 | INFO | veMQ Broker: amq | ActiveMQServiceFactory

5.8已重命名对象 作为 “类型=代理”=>“类型=代理” 这会导致异常，如问题中所述： 现在。。。 这里给出的答案 基本上就是“更改代码” 但是 我的问题和需要是怎样做 使现有JMS/JMX工具（如HermesJMS和ActiveMQBrowser）与ActiveMQ 5.8配合使用 是否有任何更新的“插件”/“提供程序”JAR可供爱马仕使用 或者有任何解决方法或合理合理的“黑客” 谢谢大家! 这两个项目都是开源的 您特别要求Hermes JMS。Source Forge有一个CVS回购协议

发现默认情况下KahaDB安装在ActiveMQ中。找到一个db.data文件，当我打开它（它是一个配置文件）时，我看到： # #Fri Aug 02 11:55:47 ART 2013 fileType=org.apache.activemq.store.kahadb.disk.page.PageFile pageSize=4096 freePages=1 cleanShutdown=false metaDataTxId=7 fileTypeVersion=1 lastTxId=52967

我得到了我的activemq配置文件和带有“jms:activemq连接器”的mule流，如下所示： <jms:activemq-connector name="Active_MQ" specification="1.1" brokerURL="failover://(tcp://localhost:61616,tcp://localhost:61617)?randomize=false" validateConnections="false" maxRedelivery="1" doc:

ActiveMQ中是否有MassTransit Saga功能的替代方案？ 作为一名学生，我学习了MassTransit，现在我想通过类比学习ActiveMQ。ActiveMQ是一个消息代理。不是长时间运行的事务状态机

我来自IBM/Oracle messaging system，在选择message broker作为SOA/microservices体系结构的决策之前。常见的候选者是来自开源空间的ActiveMQ。但在阅读了IBM的这篇文档后，我真的不确定： 我不想调查丢失或复制的邮件：-） 问题：有人能从他/她在多代理网络集群甚至主/从网络集群中运行ActiveMQ的实际经验中确认这篇IBM论文是有效的吗？或者一般来说，ActiveMQ在停机时真的会复制/丢失消息吗？我将使用负载平衡的双主从群集配置（4个

我对这句话的含糊不清感到困惑： 如果在一个队列上有多个使用者，使用者将竞争消息，ActiveMQ将在它们之间进行负载平衡，因此顺序将丢失 这是否意味着如果我有一个制作人（P1）发布一个主题（T1）和该主题的四个订阅者（S1、S2、S3、S4）。所有这些都使用AMQP 是否不能保证来自P1的消息顺序会被S1以相同的顺序看到 而其他订户不一定会看到P1实际发送的订单？） 注意，我在这里通过主题讨论jms发布/订阅：// [如果我添加了更多制作人，但每个制作人都有自己的主题队列，这会影响其他队列的顺

我试图超时监视activemq出列消息，并将它们保存在Zenoss监视系统中 我可以在activemq的控制面板中看到已退出队列的编号，但是如果重新启动activemq，这些编号将被重置 获取统计数据的最佳方式是什么 由于它的设计方式，重启后无法恢复该信息。我认为最好的办法是使用第三方监控工具Nagios、Cacti等将AMQ统计数据转储到一些甚至有AMQ插件的系统中。这些工具是为系统资源的长期监控/图表/警报而设计的，并且很容易连接到AMQ

我们使用AMQBroker5.5和Spring3.0来配置连接工厂和其他东西。 我们正在使用的连接工厂是PooledConnectionFactory，我的配置的一部分如下所示： 虚惊一场。还有另一段代码使连接保持打开状态。关闭它解决了问题 try { connection = myJmsTemplate.getConnectionFactory().createConnection(); session = connection.createSession(

我正在尝试使用ActiveMQPrefetchPolicy，但无法完全理解如何使用它 我正在使用队列，我可以为预取策略定义3个参数： queuePrefetch、queueBrowserPrefetch、inputStreamPrefetch 实际上，我不理解queueBrowserPrefetch和inputStreamPrefetch的含义，所以我不知道如何使用它。我假设您已经看到了上的ActiveMQ页面 queueBrowserPrefetch设置发送到服务器的最大消息数 直到收到确认

我对踩ActiveMQ还不熟悉。我想从android客户端创建登录，但我不知道如何使用ActiveMq。我已经安装了active mq，配置了stomp并运行了stompexample。 1.如果在activemq.xml中添加以下行，则从命令行运行activemq时出错： <transportConnector name="stomp+nio" uri="stomp+nio://localhost:61612"/> <transportConnect

我们有一个分布式应用程序，它代表多个客户机工作。现在，当工作到达时，消息被放在一个队列中。消息是按FIFO顺序提取的，大多数情况下都可以正常工作 在某些情况下，我们将为单个客户端获取数千条消息，然后这些消息将占据队列中的前一千多个插槽。这意味着，在处理这些消息之前，任何其他客户机都无法（或几乎无法）完成任何工作——这会使较小的客户机陷入饥饿 我的想法是，在我们引用客户机列表之前，每次从队列中获取消息之前，我们都会查看消息，看看是哪个客户机提交了消息。如果它是针对我们刚刚处理的同一个客户机的，我们

我想创建一个消费者，它可以堆叠到达的消息并等待： 直到n消息到达 t已过秒 处理整个消息堆栈 这不是我要找的。我真正需要的是一起处理消息 类MyListener（stomp.ConnectionListener）： def on_消息（自身、标题、正文）： 打印（“刚刚收到一条消息\n” “我应该等待n-1个其他人\n” “或处理前的t秒”） 这里是一个例子 import java.util.LinkedList; import java.util.List; import javax.j

ActiveMQ群集（主从）是否在故障切换模式下提供高可用性？ 我正在发布关于某个主题的消息，但当我关闭活动节点并且消费者连接到另一个节点时，它会丢失几条消息。 我只需要主题模式，因为我需要有不同的豆荚在同一时间消费信息。我们对持久消息和订阅进行了测试，但遇到了相同的问题 如果ActiveMQ不支持此功能，是否有其他代理可以这样做 我们使用SpringBoot开发发送者和消费者应用程序 发件人： 为了发送消息，我们使用了API REST，它向一个主题发送5000条消息。如果某个convertAn

使用侦听器设置CMS消费者涉及两个单独的调用：首先，获取消费者： cms::MessageConsumer* cms::Session::createConsumer( const cms::Destination* ); void cms::MessageConsumer::setMessageListener( cms::MessageListener* ); 然后，在使用者上设置侦听器： cms::MessageConsumer* cms::Session::createConsu

我有一个使用activeMQ消息的项目。它运行正常，但有时会在队列中遇到挂起的消息。上面说1000人排队，0人退队，1000人调度。它还说有1000条待处理的消息 “挂起的消息”的可能原因是什么？“挂起的消息”是队列中未被客户端确认的消息。这有时在队列的“消息计数”或队列的“深度”处被提及 “挂起消息”计数保持不变的最可能原因是消费者以某种方式失败。它可能陷入其他类型的阻塞网络操作中，或者完全离线 看看队列中的消费者数量。如果大于0，则消费者仍处于连接状态。此时，您应该检查各个消费者。假设客户机

我的示例JMS布局在这里有一个小问题 我在两台机器上有两个代理（A、B），它们通过网络连接器链接。其思想是制作人可以发送给任何代理，消费者可以收听任何代理，发送给/接收的主题在全球范围内可用 主题有两个持久订户客户端（每台机器上一个），它们都将处理主题中的所有消息。我希望它是一个持久的订阅，以便在必须重新启动进程时，进程不会失去任何工作负载。这两个订阅服务器客户端都配置为具有故障转移代理url，以便它们首先尝试连接到本地主机代理，如果另一个不可用，则尝试连接到本地主机代理。客户端的故障切换似乎正

在中，据说消息组提供了跨多个使用者处理消息的负载平衡 虽然我读了整篇文章，但我还没有理解消息组和负载平衡之间的关系。毕竟，在消息组之前已经有了负载平衡：MessageBroker根据消费者的确认速度来调度消息。因此，如果有与消息组相关的负载平衡，那么就粒度而言，它是一个更大的负载平衡 对吗 任何评论或见解都将不胜感激。好吧，这并没有那么复杂，文档中可能会有些混乱 正如您所说，负载平衡是内置的，因为代理在可用消费者之间分发消息。消息组通常必须表示需要由单个节点（或线程）处理的单元，甚至由于应用程序

是否有任何PoC可以证明ActiveMQ在垂直（速度）和水平（可伸缩性）方面具有良好的性能？使用或不使用Spring JMS 因为我看到它不能在超过50个事务/秒的时间内处理小消息。当我使用Spring JMS时，消费者只会缓慢地增加（我设置Max CurrutsCuffer-Currut消费者）有很多细节要考虑。你每秒有50个味精什么？持久消息？非持久性？你在排队吗？关于主题的持久订阅者？你在用选择器吗？请求/答复？交易？你的瓶颈在哪里？经纪人本身？消费者？制片人？除非您查看一个非常特定场景的

我们将ActiveMQ 5.8.0与SpringJMS 3.2.3.0结合使用。应用程序使用SpringDefaultMessageListenerContainer侦听队列，并使用SpringMappingJackson2MessageConverter将对象存储在ActiveMQTextMessage中 我们还使用ActiveMQ代理重新交付插件，该插件在ActiveMQ.xml中配置。消息保存在Oracle数据库中，该数据库也在activemq.xml中配置 现在我们有以下问题：在重新传递

以下是我尝试使用ActiveMQ实现的目标： 我想要两组经纪人：clusterA和clusterB。这两个集群之间的数据应该被镜像。因此，当clusterA收到一条消息时，它将被存储在storageA中，并且该消息也应该被转发到clusterB（如果有这样的需求）并存储在storageB中。另一方面，如果clusterB收到消息，则应将其转发给clusterA。 我想知道根据上面的描述，这样的配置是否被认为是有效的： <networkConnectors> <n

我正在一个项目中使用ActiveMQ CPP，希望启动一个嵌入式代理。我找到了对“MockBrokerService”的引用，但找不到相关文档。我的发现表明这是为了测试。ActudiMQCPP是否支持启动一个完全功能的嵌入式代理，可以与其他ActuMeq实例进行故障转移等交互操作？ < P> C++客户端只是一个客户端，没有C++代理，所以它不能启动嵌入式代理。只有Java客户机可以这样做，并且只有在包含activemq代理依赖项和预期配置所需的任何其他代理库的情况下

我在ActiveMQ中遇到了一个问题，当主Zookeeper节点脱机时，整个集群将失败 我们在开发环境中有一个3节点的ActiveMQ集群设置。每个节点都有ActiveMQ 5.12.0和Zookeeper 3.4.6（*注意，我们已经使用Zookeeper 3.4.7进行了一些测试，但这并没有解决问题。到目前为止，时间限制使我们无法测试ActiveMQ 5.13） 我们发现，当我们停止主ZooKeeper进程（通过任务管理器中的“结束进程树”命令）时，其余两个ZooKeeper节点继续正常工作

代理URL failover:(tcp://broker1:61616,tcp://broker2:61616)?randomize=false&jms.useAsyncSend=false&jms.dispatchAsync=false&maxReconnectAttempts=2&maxReconnectDelay=100 我在活动代理上注册了一个消息侦听器： Destination destQueue = new ActiveMQQueue("queu

我正在进行Corda V2项目，但不久将迁移到V3。根据 阿耳特弥斯隐藏在一个薄界面后面 但我正在探索一些商业案例。具体来说，是否为配置公开了以下任何内容？在中找不到任何特定内容，但即将查看源代码。或者我需要做我自己的代理并用messagingServerAddress指定吗 传递重试率 退避率 超时，或者当Artemis放弃传递消息时 抱歉，这可能是一个单独的问题，但是否可以查询内部队列以查看节点是否已提议发送到其他节点？从Corda 3开始，这些设置是不可配置的 建议不要尝试干扰这些设置，因

我目前正在从事一个项目，其中一个外部应用程序通过MQTT协议发送来自多个传感器的数据 我想收集所有这些数据，并将它们发送到外部服务器。我想创建2个MQTT代理： 一个本地（在带有发送数据的应用程序的机器上） 远程服务器中的一个 我将在两者之间创建一个网络桥。这是我的MQTT服务器应用程序ActiveMQ提供的一种可能性（我想这是一个常见特性） 这样，数据生成应用程序将在本地代理上发布，并通过网桥在远程代理上发布相同的数据。关键是让应用程序在连接丢失的情况下正常工作 当我失去了代理之间的网络连

我想满足以下要求： 14.3.3验证HTTP头或HTTP响应的任何部分是否未公开系统组件的详细版本信息 对于ActiveMQ代理。 我对STOMPprotocolCONNECTED消息有问题，该消息如下所示： CONNECTED server:ActiveMQ/5.15.9 heart-beat:0,10000 session:ID:localhost.local-36323-1578488170638-3:15 version:1.2 user-name:user@example.com 并

我从带有JDBC Oracle支持的持久性的ActiveMQ 5.9.0中得到了一个稍微奇怪的警告 WARN [org.apache.activemq.store.jdbc.LeaseDatabaseLocker] LockableService keep alive period: 2000, which renews the lease, is less than lockAcquireSleepInterval: 1000, the lease duration.

我编写了一个风暴拓扑，用它的喷口收听卡夫卡的特定主题。现在我必须在activeMQ上迁移它。是否可以使用activeMQ重现这些主题，并创建像我使用卡夫卡那样聆听它们的喷口 我在谷歌上搜索了一下，但不清楚如何向某个主题发送消息或收听某个特定主题。在卡夫卡，你可以这样做 data = new KeyedMessage<>("topic", sms); producer.send(data); Queue queue = session.createQueue("topic"); co

我想重写BrokerFilter类的send（）方法 此方法有两个参数：ProducerBrokerExchange和Message 我可以从这两个参数中获取目标队列的大小吗 我正在使用activemq-all-5.13.2.jar。您可以使用： BrokerFilter.getRegionDestination().getDestinationStatistics().getMessages().getCount(); 您在org.apache.activemq.broker.region.

我对ActiveMQ一无所知。我试图通过检查Apache在以下链接提供的示例代码来研究和检查它是如何工作的：- 我对messageBrokerUrl=的困惑tcp://localhost:61616"; 您知道ActiveMQ服务默认在端口61616上运行。为什么本例选择相同的端口。如果我尝试以以下方式运行代码： 异常：无法绑定到服务器套接字：tcp://localhost:61616 由于：java.net.BindException:地址已在使用中：JVM\u Bind 也许如果我更改端

因此，“”的文档说明： 所选的主代理节点启动并接受客户端连接。其他节点进入从属模式，连接主节点并与之同步其持久状态从属节点不接受客户端连接。所有持久性操作都复制到连接的从属设备。如果主服务器死亡，具有最新更新的从属服务器将升级为主服务器。然后，故障节点可以重新联机，并将进入从属模式 因此，一个选定的主节点存在，它接受客户端连接，其余的是不接受客户端连接的复制从属节点。好的 因此，如果主服务器死了，一切正常——主服务器重新当选，客户端断开连接，最终连接到新的主服务器。太棒了 现在，从Zookeep

应用程序中以下ActiveMQ对象的范围是什么 连接（每个应用程序一个吗？） 会话（每个应用程序一个？） 生产者 消费者 我正在设计一个发送大量消息的应用程序，我需要知道我是否可以在应用程序中使用连接、会话、生产者和消费者中的一种。这些取决于各种设置，本页对概念进行了很好的总结

我们在Tomcat6.0.35上运行activeMQ5.6作为嵌入式代理，消息传递选项设置为持久。我们正在解决一个消费者方面的记忆问题。消费者的速度很慢，因为他们的工作很耗时。我们通常在跑步8-10小时后得到OOM。在处理3000条消息后，必须处理约10000条消息，其余7000条消息保持挂起状态。消息大小非常小，xml格式为1KB。虽然我们在diff队列上还有其他用户速度非常快，并且发布了约10000条消息，消息大小相当高，约100KB，但我们在该队列上没有得到OOM。虽然它是在同一个代理上设

我有一些带mina插座和码头网插座的骆驼路线。我能够向连接到websocket的所有客户端广播消息，但如何将消息发送到特定端点。如何维护所有连接的客户端的列表，并以客户端id作为参考，以便路由到特定客户端。可能吗？我能在to URI中提到动态客户端吗 或者我可能认为这是错误的，我需要在活动mq上创建主题，并让客户端订阅它。这意味着我要为每个websocket客户端创建一个主题？并将消息发送到正确的主题 我至少在这方面是正确的吗，你能指出一些例子吗？谷歌没有帮助。您肯定不想为每个客户端创建单独的端

我正在从事一个项目，在这个项目中，多个工作人员从一个作业队列接收STOMP消息进行处理，我们希望支持优先级。目前，我们正在使用ActiveMQ，但我们无法让内置的优先级支持正常工作，不得不求助于使用多个队列，每个优先级一个队列。这是可行的，但因为每个队列的缓冲区中始终至少有一个未确认的消息客户端等待确认。如果数千条消息以一种优先级出现，那么可以想象，低优先级缓冲区中的任何消息一次都会在那里停留数小时甚至数天 如果我们可以轮询服务器以获取消息，而不是被动地等待，那就太好了，但这似乎不受支持，除非我

我在通过ActiveMQ 5.8使用MCollective的直接寻址时遇到问题。（） 当通过MCollective订阅节点队列的一个节点崩溃并且没有取消订阅时，就会出现问题。当主机再次引导和订阅时，现在有两个具有相同身份的订阅方，因为ActiveMQ无法识别崩溃前的订阅方不再侦听。这是直接寻址的一个问题，因为它进入队列，ActiveMQ只向一个订户发送消息，而且它似乎总是选择不侦听的订户；因此，消息永远不会传递到实际节点。如果让ActiveMQ记录消息帧，我可以观察到这种情况 这可能与Activ

我已经安装了apollo 1.7.1，并使用默认设置的代理。当我尝试连接到此代理时，收到此错误消息 Authentication failed. Credentials=[] 默认情况下，它附带基于文件的身份验证设置。如何禁用此身份验证？Apache Apollo已过时/不再开发，我建议使用常规的ActiveMQ或ActiveMQ Artemis。谢谢克劳斯。我会记住这一点。

是否可以在ActiveMQ 5（经典）中禁止对通配符的主题订阅 例如，订阅>将向所有消费者广播所有消息，即使消费者不能订阅所有主题（甚至不知道所有主题） 我已经尝试使用创建，但无法禁止通配符订阅 您是否知道如何为特定/所有用户完成通配符订阅或将消息转发到通配符？如评论中所述，您从错误的方向处理此问题。正确的方法不是试图禁用通配符订阅，而是限制实际传递的主题，而不管订阅的是什么 这是通过为每个用户设置适当的ACL来实现的（对500k客户端重复使用相同的凭据是一个非常糟糕的主意） ActiveMQ使