2021-02-25 11:00:34,661 | WARN | SASL configuration failed: javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found in specified JAAS configuration file: '/mq_cluster/mq_node01//conf/login.config'. Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it. | org.apache.zookeeper.ClientCnxn | main-SendThread(xxx:2288) 2021-02-25 11:00:34,662 | INFO | Opening socket connection to server xxx/xxx:2288 | org.apache.zookeeper.ClientCnxn | main-SendThread(xxx:2288) 2021-02-25 11:00:34,662 | INFO | S

被这个折磨好久了。。。网上找也基本都是持久化到mysql的

2022-09-02 11:51:14,794 | ERROR | Failed to start Apache ActiveMQ (localhost, null) | org.apache.activemq.broker.BrokerService | WrapperSimpleAppMain java.io.IOException: Detected missing/corrupt journal files referenced by:[0:ActiveMQ.DLQ] 24730 messages affected. at org.apache.activemq.store.kahadb.MessageDatabase.recoverIndex(MessageDatabase.java:965)[activemq-kahadb-store-5.15.2.jar:5.15.2] at org.apache.activemq.store.kahadb.MessageDatabase$5.execute(MessageDatabase.java:717)[activemq-kahadb-store-5.15.2.jar:5.15.2] at org.apache.activemq.store.kahadb.disk.page.Transaction.execute(Transac

jvm 1 | at java.net.ServerSocket.bind(Unknown Source) jvm 1 | at java.net.ServerSocket.<init>(Unknown Source) jvm 1 | at javax.net.DefaultServerSocketFactory.createServerSocket(Unkno wn Source) jvm 1 | at org.apache.activemq.transport.tcp.TcpTransportServer.bind(Tcp TransportServer.java:135) jvm 1 | ... 51 more jvm 1 | INFO | ActiveMQ Message Broker (localhost, null) is shutting down jvm 1 | INFO | Connector duan Stopped jvm 1 | INFO | PListStore:..\..\data\localhost\tmp_storage stopped jvm 1 | INFO | Stopping async queue tasks jvm 1 | INFO | Stopping async topic tasks jvm 1 | INFO | Sto

在windows环境用Java写的一个main方法，activemq是5.15.5版本，部署在linux上。

我是学习Java的，刚开始学习的时候，觉得还是可以的，并没有想象中的那么难，

刚开始学习Java的时候觉得还是可以的，

Mac升级10.15后，MQ启动报错 ， Bad CPU type in executable ，之前10.14的时候好好的

ActiveMQ MQTT设备的离线在线状态怎么获取，如何实时上报设备的在线离线状态，请大神指导

AdvisorySupport.getProducerAdvisoryTopic 使用MQTT 协议 监听不了publish 的问题

请教一个问题，消费者 执行数据库插入操作，commit完后宕机了，消费者没有调用acknowledge返回确认，这样queue里面的任务没有删除掉，服务恢复后，就会再次消费这个任务，数据不就重复插入了吗? 这种情况应该怎么办？

学习中遇到两个问题，activemq使用中是用什么机制保证自己多个主题或者消息队列不重名，还有一个是消息队列生命周期，正常和异常情况

第一节(同步请求概念介绍) 第二节(为什么要使用消息中间件) 第三节(消息中间件通讯方式) 第四节(消息中间使用场景) 第五节(windows环境安装ActiveMQ) 第六节(ActiveMQ生产者) 第七节(ActiveMQ消费者) 第八节(ActiveMQ发布订阅)

activeMQ,DestinationDoesNotExistException,发送topic消息报的异常，the destination temp-topic://item-add-topic does not exist，但换成queue可以发送和接收消息，求大神帮个忙，看看咋回事

目前使用的版本是activemq5.13.0,在使用过程中发现Scheduled(计划任务)所产生的日志不会自动清理，只能等到服务重启再对旧文件手动清理，有懂的麻烦指点一二谢谢

如题

Windows7第一次安装 activeMQ ICS服务也关闭了

activemq视频教程+QQ616993639 一、ActiveMQ教程基础部分 1.ActiveMQ入门和消息中间件 2.JMS基本概念和模型 3.JMS的可靠性机制 4.JMS的API结构和开发步骤 5.Broker的启动方式 6.ActiveMQ结合Spring开发 7.ActiveMQ支持的传输协议 8.ActiveMQ消息存储持久化 9.ActiveMQ的静态网络链接 10.多线程consumer访问集群 二、ActiveMQ教程中级部分 第11节：集群下的消息回流功能第 12节：容错的链接和动态网络连接第 13节：ActiveMQ的集群第 14节：Destination高级特性一第 15节：Destination高级特性二第 16

Java语言完全满足了PC的条件，在减少内存，直接在各类电子产品中运行，在网络中可被任何设备所识别，充分利用网络资源等方面有所突破创新，为PC时代的发展创造了有力条件。 Java语言独有的特点，根据其在各项服务器中应用程序的开发所占有的优势，企业版的J2SE为企业环境中计算机模式的应用提供了良好的平台。 快速掌握和应用Java编程技术，我们的教程也深刻的从内存结构进行分析、JDK源代码进行分析，这都是高手的必备技能。 java高级开发工

利用MessageListener获取到的信息里clientid为空，客户端是安卓，使用的mqtt，服务端是java

有没有大神了解activeMQ+STOMP 求帮助！

消息模式：topic订阅 实现了TransprotListener 监听连接状态！ 采用failover方式的url 问题是：当网络异常时，发送消息阻塞，过了大概10-20秒 TransprotListener才监听到mq断开连接，而不是马上输出连接终端

我在虚拟机解压了ActiveMQ,进入到bin目录，执行./activemq start，然后到Windows下浏览器里面输入ip:8161，为什么进不去ActiveMQ的界面啊？求指导，谢谢！

topic 消息持久化到MYSQL后，持久订阅者都已经消费完了，而MQ却不删除消息。queue方式没有这个问题。 重启之后，发现topic消息被删除了。 这样的话，一直不删除服务器要爆啊。。。 谁有解决方法？

请问activemq的许可证是啥啊，领导让我查一批开源软件许可证，其中刚好有这个，求大神帮忙

java.lang.IllegalStateException: No message listener specified - see property 'messageListener' at org.springframework.jms.listener.AbstractMessageListenerContainer.invokeListener(AbstractMessageListenerContainer.java:507) at org.springframework.jms.listener.AbstractMessageListenerContainer.doExecuteListener(AbstractMessageListenerContainer.java:468) at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.doReceiveAndExecute(AbstractPollingMessageListenerContainer.java:325) at org.springframework.jms.listener.AbstractPollingMessageListenerContainer.receiveAndExecute

镇楼

请教下，我现在要实现4个activemq之间互传消息，我怎样让本地消费客户端不消费自己本地队列里的消息呢？

Activemq5.8发文件时出现put was not successful 401 unauthorized，求问怎么解决，参考了网上的几种解决方案，还是不行，求指导。

求哪位大声告知！！最近在做一个项目，用到了Activemq ,用的是订阅模式，但是有一个问题，忘topic中插数据时，topic的订阅者收到了之后，topic中内容消息数量一直在增加，如何把消息数量限制在一定的程度啊！！！！？？？？？看到了网上说配置activemq.xml中的fixedSizeSubscriptionRecoveryPolicy,但是没用啊！！！

JMS&ActiveMQ实战(JMS+ActiveMQ+Drools)

activemq消费端部署怎么才能不影响业务

jvm 1 | at java.net.ServerSocket.bind(Unknown Source) jvm 1 | at java.net.ServerSocket.<init>(Unknown Source) jvm 1 | at javax.net.DefaultServerSocketFactory.createServerSocket(Unkno wn Source) jvm 1 | at org.apache.activemq.transport.tcp.TcpTransportServer.bind(Tcp TransportServer.java:135) jvm 1 | ... 51 more jvm 1 | INFO | ActiveMQ Message Broker (localhost, null) is shutting down jvm 1 | INFO | Connector duan Stopped jvm 1 | INFO | PListStore:..\..\data\localhost\tmp_storage stopped jvm 1 | INFO | Stopping async queue tasks jvm 1 | INFO | Stopping async topic tasks jvm 1 | INFO | Sto

大神们，怎样往部署好的activemq上加功能，这个功能是用监听写的

有遇到相同的问题的吗？ 如何解决？（除修改系统时间外）

不太会用啊！求指点！

亲爱的各位吧友：欢迎来到activemq