Are you using the recommended lease-locker, instead of the default locker?
See: https://activemq.apache.org/pluggable-storage-lockers
Example config snippet:
<persistenceAdapter>
<jdbcPersistenceAdapter dataDirectory="${activemq.data}"
dataSource="#mysql-ds" lockKeepAlivePeriod="5000">
<locker>
<lease-database-locker
lockAcquireSleepInterval="10000"/>
</locker>
</jdbcPersistenceAdapter>
</persistenceAdapter>
-Matt Pavlovich
> On Jun 27, 2023, at 3:00 AM, ヤ艾枫o.-- <1169114...@qq.com.INVALID> wrote:
>
> Same as using the latest version, there is no data in the ACTIVEMQ_LOCK.
> Is the configuration file missing content
>
>
>
> ヤ艾枫o.--
> 1169114...@qq.com
>
> <https://wx.mail.qq.com/home/index?t=readmail_businesscard_midpage&nocheck=true&name=%E3%83%A4%E8%89%BE%E6%9E%ABo.--&icon=https%3A%2F%2Fres.mail.qq.com%2Fzh_CN%2Fhtmledition%2Fimages%2Frss%2Fmale.gif%3Frand%3D1617349242&mail=1169114186%40qq.com&code=>
>
>
>
> ------------------ 原始邮件 ------------------
> 发件人: "users" <mattr...@gmail.com>;
> 发送时间: 2023年6月27日(星期二) 凌晨3:21
> 收件人: "users@activemq.apache.org"<users@activemq.apache.org>;
> 主题: Re: When I used JDBC to connect MySQL to build a 2-node master-slave, I
> found that the table ACTIVEMQ in the database_ LOCK No data
>
> Hi-
>
> 5.15.x is no longer actively supported by the community. If you are seeking
> community support, please upgrade to 5.18.1 and report back. There were a lot
> of SQL-based improvements since 5.15.9.
>
> Thanks!
> Matt Pavlovich
>
> > On Jun 26, 2023, at 6:09 AM, ヤ艾枫o.-- <1169114...@qq.com.INVALID> wrote:
> >
> > Hello
> > When I used JDBC to connect MySQL to build a 2-node
> > master-slave, I found that the table ACTIVEMQ in the database_ LOCK No
> > data，5.15.9 version
> >
> >
> > ---activemq.log 2node the log is same-----
> >
> > 2023-06-26 18:27:30,140 | INFO | Refreshing
> > org.apache.activemq.xbean.XBeanBrokerFactory$1@1a968a59: startup date [Mon
> > Jun 26 18:27:30 CST 2023]; root of context hierarchy |
> > org.apache.activemq.xbean.XBeanBrokerFactory$1 | main
> >
> > 2023-06-26 18:27:31,116 | INFO | Using Persistence Adapter:
> > JDBCPersistenceAdapter(org.apache.commons.dbcp2.BasicDataSource@cb0755b) |
> > org.apache.activemq.broker.BrokerService | main
> >
> > 2023-06-26 18:27:31,651 | INFO | Database adapter driver override not
> > found for : [mysql_connector_j]. Will use default implementation. |
> > org.apache.activemq.store.jdbc.JDBCPersistenceAdapter | main
> >
> > 2023-06-26 18:27:31,756 | INFO | Database lock driver override not
> > found for : [mysql_connector_j]. Will use default implementation. |
> > org.apache.activemq.store.jdbc.JDBCPersistenceAdapter | main
> >
> > 2023-06-26 18:27:31,758 | INFO | Attempting to acquire the exclusive
> > lock to become the Master broker |
> > org.apache.activemq.store.jdbc.DefaultDatabaseLocker | main
> >
> > 2023-06-26 18:27:31,763 | INFO | Becoming the master on dataSource:
> > org.apache.commons.dbcp2.BasicDataSource@cb0755b |
> > org.apache.activemq.store.jdbc.DefaultDatabaseLocker | main
> >
> > 2023-06-26 18:27:31,766 | INFO |
> > PListStore:[/activemq-data/jjdbcBroker/tmp_storage] started |
> > org.apache.activemq.store.kahadb.plist.PListStoreImpl | main
> >
> > 2023-06-26 18:27:31,905 | INFO | Apache ActiveMQ 5.15.9 (jjdbcBroker,
> > ID:new234-rocketmq-master-1-edece-0.hde.com-35445-1687775251776-0:1) is
> > starting | org.apache.activemq.broker.BrokerService | main
> >
> > 2023-06-26 18:27:31,941 | INFO | Listening for connections at:
> > tcp://new234-rocketmq-master-1-edece-0.hde.com:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600
> > | org.apache.activemq.transport.TransportServerThreadSupport | main
> >
> > 2023-06-26 18:27:31,943 | INFO | Connector default started |
> > org.apache.activemq.broker.TransportConnector | main
> >
> > 2023-06-26 18:27:31,944 | INFO | Apache ActiveMQ 5.15.9 (jjdbcBroker,
> > ID:new234-rocketmq-master-1-edece-0.hde.com-35445-1687775251776-0:1)
> > started | org.apache.activemq.broker.BrokerService | main
> >
> > 2023-06-26 18:27:31,945 | INFO | For help or more information please
> > see: http://activemq.apache.org | org.apache.activemq.broker.BrokerService
> > | main
> >
> > 2023-06-26 18:27:31,947 | WARN | Store limit is 102400 mb (current
> > store usage is 0 mb). The data directory: / only has 32509 mb of usable
> > space. - resetting to maximum available disk space: 32509 mb |
> > org.apache.activemq.broker.BrokerService | main
> >
> > 2023-06-26 18:27:31,948 | WARN | Temporary Store limit is 51200 mb
> > (current store usage is 0 mb). The data directory: / only has 32509 mb of
> > usable space. - resetting to maximum available disk space: 32509 mb |
> > org.apache.activemq.broker.BrokerService | main
> >
> > 2023-06-26 18:27:32,567 | INFO | No Spring WebApplicationInitializer
> > types detected on classpath | /admin | main
> >
> > 2023-06-26 18:27:32,663 | INFO | ActiveMQ WebConsole available at
> > http://0.0.0.0:8161/ | org.apache.activemq.web.WebConsoleStarter | main
> >
> > 2023-06-26 18:27:32,664 | INFO | ActiveMQ Jolokia REST API available
> > at http://0.0.0.0:8161/api/jolokia/ |
> > org.apache.activemq.web.WebConsoleStarter | main
> >
> > 2023-06-26 18:27:32,708 | INFO | Initializing Spring FrameworkServlet
> > 'dispatcher' | /admin | main
> >
> > 2023-06-26 18:27:32,874 | INFO | No Spring WebApplicationInitializer
> > types detected on classpath | /api | main
> >
> > 2023-06-26 18:27:32,943 | INFO | jolokia-agent: Using policy access
> > restrictor classpath:/jolokia-access.xml | /api | main
> >
> >
> >
> >
> >
> >
> >
> >
> >
> >
> > -----activemq.xml----
> >
> >
> >
> > <beans
> >
> > xmlns="http://www.springframework.org/schema/beans";
> >
> > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
> >
> > xsi:schemaLocation="http://www.springframework.org/schema/beans
> > http://www.springframework.org/schema/beans/spring-beans.xsd
> >
> > http://activemq.apache.org/schema/core
> > http://activemq.apache.org/schema/core/activemq-core.xsd">
> >
> >
> >
> > <!-- Allows us to use system properties as variables in
> > this configuration file -->
> >
> > <bean
> > class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
> >
> > <property name="locations">
> >
> >
> > <value>file:${activemq.conf}/credentials.properties</value>
> >
> > </property>
> >
> > </bean>
> >
> >
> >
> > <!-- Allows accessing the server log -->
> >
> > <bean id="logQuery"
> > class="io.fabric8.insight.log.log4j.Log4jLogQuery"
> >
> > lazy-init="false"
> > scope="singleton"
> >
> > init-method="start"
> > destroy-method="stop">
> >
> > </bean>
> >
> >
> >
> > <!--
> >
> > The <broker> element is used
> > to configure the ActiveMQ broker.
> >
> > -->
> >
> > <broker xmlns="http://activemq.apache.org/schema/core";
> > brokerName="jjdbcBroker">
> >
> >
> >
> > <destinationPolicy>
> >
> >
> > <policyMap>
> >
> >
> > <policyEntries>
> >
> >
> > <policyEntry topic=">" >
> >
> >
> > <!-- The constantPendingMessageLimitStrategy is used to prevent
> >
> >
> > slow topic consumers to block producers and affect other consumers
> >
> >
> > by limiting the number of messages that are retained
> >
> >
> > For more information, see:
> >
> >
> >
> >
> > http://activemq.apache.org/slow-consumer-handling.html
> >
> >
> >
> >
> > -->
> >
> >
> > <pendingMessageLimitStrategy>
> >
> >
> > <constantPendingMessageLimitStrategy limit="1000"/>
> >
> >
> > </pendingMessageLimitStrategy>
> >
> >
> > </policyEntry>
> >
> >
> > </policyEntries>
> >
> >
> > </policyMap>
> >
> > </destinationPolicy>
> >
> >
> >
> >
> >
> > <!--
> >
> > The
> > managementContext is used to configure how ActiveMQ is exposed in
> >
> > JMX. By
> > default, ActiveMQ uses the MBean server that is started by
> >
> > the JVM.
> > For more information, see:
> >
> >
> >
> >
> > http://activemq.apache.org/jmx.html
> >
> > -->
> >
> > <managementContext>
> >
> >
> > <managementContext createConnector="false"/>
> >
> > </managementContext>
> >
> >
> >
> > <!--
> >
> >
> > Configure message persistence for the broker. The default persistence
> >
> >
> > mechanism is the KahaDB store (identified by the kahaDB tag).
> >
> > For more
> > information, see:
> >
> >
> >
> >
> > http://activemq.apache.org/persistence.html
> >
> > -->
> >
> > <persistenceAdapter>
> >
> >
> > <jdbcPersistenceAdapter dataDirectory="${activemq.base}/activemq-data"
> > dataSource="#mysql-ds" createTablesOnStartup="true"/>
> >
> >
> >
> > </persistenceAdapter>
> >
> >
> >
> >
> >
> >
> >
> > <!--
> >
> > The
> > systemUsage controls the maximum amount of space the broker will
> >
> > use
> > before disabling caching and/or slowing down producers. For more
> > information, see:
> >
> >
> > http://activemq.apache.org/producer-flow-control.html
> >
> > -->
> >
> > <systemUsage>
> >
> >
> > <systemUsage>
> >
> >
> > <memoryUsage>
> >
> >
> > <memoryUsage percentOfJvmHeap="70" />
> >
> >
> > </memoryUsage>
> >
> >
> > <storeUsage>
> >
> >
> > <storeUsage limit="100 gb"/>
> >
> >
> > </storeUsage>
> >
> >
> > <tempUsage>
> >
> >
> > <tempUsage limit="50 gb"/>
> >
> >
> > </tempUsage>
> >
> >
> > </systemUsage>
> >
> > </systemUsage>
> >
> >
> >
> > <!--
> >
> > The
> > transport connectors expose ActiveMQ over a given protocol to
> >
> > clients
> > and other brokers. For more information, see:
> >
> >
> >
> >
> > http://activemq.apache.org/configuring-transports.html
> >
> > -->
> >
> > <transportConnectors>
> >
> > <!-- DOS
> > protection, limit concurrent connections to 1000 and frame size to 100MB
> > -->
> >
> >
> > <transportConnector name="default"
> > uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
> >
> > </transportConnectors>
> >
> >
> >
> > <!-- destroy the spring context
> > on shutdown to stop jetty -->
> >
> > <shutdownHooks>
> >
> > <bean
> > xmlns="http://www.springframework.org/schema/beans";
> > class="org.apache.activemq.hooks.SpringContextHook" />
> >
> > </shutdownHooks>
> >
> >
> >
> > </broker>
> >
> >
> >
> > <!--
> >
> > Enable web consoles, REST and
> > Ajax APIs and demos
> >
> > The web consoles requires by
> > default login, you can disable this in the jetty.xml file
> >
> >
> >
> > Take a look at
> > ${ACTIVEMQ_HOME}/conf/jetty.xml for more details
> >
> > -->
> >
> > <bean id="mysql-ds"
> > class="org.apache.commons.dbcp2.BasicDataSource" destroy-method="close">
> >
> > <property name="driverClassName"
> > value="com.mysql.jdbc.Driver"/>
> >
> > <property name="url"
> > value="jdbc:mysql://localhost:3306/activemq?relaxAutoCommit=true"/>
> >
> > <property name="username"
> > value="xxxxx"/>
> >
> > <property name="password"
> > value="xxxxx"/>
> >
> > <property
> > name="poolPreparedStatements" value="true"/>
> >
> > </bean>
> >
> > <import resource="jetty.xml"/>
> >
> >
> >
> > </beans>
> >
> > <!-- END SNIPPET: example -->
