Same as using the latest version, there is no data in the ACTIVEMQ_LOCK. Is the configuration file missing content
??????o.-- 1169114...@qq.com ------------------ ???????? ------------------ ??????: "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 > &nbsp; &nbsp;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&nbsp; 2node the log is same----- > > 2023-06-26 18:27:30,140 | INFO&nbsp; | 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&nbsp; | Using Persistence Adapter: JDBCPersistenceAdapter(org.apache.commons.dbcp2.BasicDataSource@cb0755b) | org.apache.activemq.broker.BrokerService | main > > 2023-06-26 18:27:31,651 | INFO&nbsp; | Database adapter driver override not found for : [mysql_connector_j].&nbsp; Will use default implementation. | org.apache.activemq.store.jdbc.JDBCPersistenceAdapter | main > > 2023-06-26 18:27:31,756 | INFO&nbsp; | Database lock driver override not found for : [mysql_connector_j].&nbsp; Will use default implementation. | org.apache.activemq.store.jdbc.JDBCPersistenceAdapter | main > > 2023-06-26 18:27:31,758 | INFO&nbsp; | 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&nbsp; | 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&nbsp; | PListStore:[/activemq-data/jjdbcBroker/tmp_storage] started | org.apache.activemq.store.kahadb.plist.PListStoreImpl | main > > 2023-06-26 18:27:31,905 | INFO&nbsp; | 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&nbsp; | Listening for connections at: tcp://new234-rocketmq-master-1-edece-0.hde.com:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600 | org.apache.activemq.transport.TransportServerThreadSupport | main > > 2023-06-26 18:27:31,943 | INFO&nbsp; | Connector default started | org.apache.activemq.broker.TransportConnector | main > > 2023-06-26 18:27:31,944 | INFO&nbsp; | 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&nbsp; | 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&nbsp; | 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&nbsp; | 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&nbsp; | No Spring WebApplicationInitializer types detected on classpath | /admin | main > > 2023-06-26 18:27:32,663 | INFO&nbsp; | ActiveMQ WebConsole available at http://0.0.0.0:8161/ | org.apache.activemq.web.WebConsoleStarter | main > > 2023-06-26 18:27:32,664 | INFO&nbsp; | 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&nbsp; | Initializing Spring FrameworkServlet 'dispatcher' | /admin | main > > 2023-06-26 18:27:32,874 | INFO&nbsp; | No Spring WebApplicationInitializer types detected on classpath | /api | main > > 2023-06-26 18:27:32,943 | INFO&nbsp; | jolokia-agent: Using policy access restrictor classpath:/jolokia-access.xml | /api | main > > > > > > > > > > > -----activemq.xml---- > > > > <beans > > &nbsp; xmlns="http://www.springframework.org/schema/beans" > > &nbsp; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" > > &nbsp; xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd > > &nbsp; http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd"&gt; > > &nbsp; > > &nbsp;&nbsp;&nbsp; <!-- Allows us to use system properties as variables in this configuration file --&gt; > > &nbsp;&nbsp;&nbsp; <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <property name="locations"&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <value&gt;file:${activemq.conf}/credentials.properties</value&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </property&gt; > > &nbsp;&nbsp;&nbsp; </bean&gt; > > &nbsp; > > &nbsp;&nbsp; <!-- Allows accessing the server log --&gt; > > &nbsp;&nbsp;&nbsp; <bean id="logQuery" class="io.fabric8.insight.log.log4j.Log4jLogQuery" > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; lazy-init="false" scope="singleton" > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; init-method="start" destroy-method="stop"&gt; > > &nbsp;&nbsp;&nbsp; </bean&gt; > > &nbsp; > > &nbsp;&nbsp;&nbsp; <!-- > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; The <broker&gt; element is used to configure the ActiveMQ broker. > > &nbsp;&nbsp;&nbsp; --&gt; > > &nbsp;&nbsp;&nbsp; <broker xmlns="http://activemq.apache.org/schema/core" brokerName="jjdbcBroker"&gt; > > &nbsp; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <destinationPolicy&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <policyMap&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <policyEntries&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <policyEntry topic="&gt;" &gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <!-- The constantPendingMessageLimitStrategy is used to prevent > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; slow topic consumers to block producers and affect other consumers > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; by limiting the number of messages that are retained > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; For more information, see: > > &nbsp; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; http://activemq.apache.org/slow-consumer-handling.html > > &nbsp; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; --&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <pendingMessageLimitStrategy&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <constantPendingMessageLimitStrategy limit="1000"/&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </pendingMessageLimitStrategy&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</policyEntry&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </policyEntries&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </policyMap&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </destinationPolicy&gt; > > &nbsp; > > &nbsp; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <!-- > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; The managementContext is used to configure how ActiveMQ is exposed in > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; JMX. By default, ActiveMQ uses the MBean server that is started by > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; the JVM. For more information, see: > > &nbsp; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; http://activemq.apache.org/jmx.html > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; --&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <managementContext&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <managementContext createConnector="false"/&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </managementContext&gt; > > &nbsp; > > &nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<!-- > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Configure message persistence for the broker. The default persistence > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; mechanism is the KahaDB store (identified by the kahaDB tag). > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; For more information, see: > > &nbsp; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; http://activemq.apache.org/persistence.html > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; --&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <persistenceAdapter&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <jdbcPersistenceAdapter dataDirectory="${activemq.base}/activemq-data" dataSource="#mysql-ds" createTablesOnStartup="true"/&gt; > > &nbsp; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </persistenceAdapter&gt; > > &nbsp; > > &nbsp; > > &nbsp; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <!-- > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; The systemUsage controls the maximum amount of space the broker will > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; use before disabling caching and/or slowing down producers. For more information, see: > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; http://activemq.apache.org/producer-flow-control.html > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; --&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <systemUsage&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <systemUsage&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <memoryUsage&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <memoryUsage percentOfJvmHeap="70" /&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </memoryUsage&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <storeUsage&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <storeUsage limit="100 gb"/&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </storeUsage&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <tempUsage&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <tempUsage limit="50 gb"/&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </tempUsage&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </systemUsage&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </systemUsage&gt; > > &nbsp; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <!-- > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; The transport connectors expose ActiveMQ over a given protocol to > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; clients and other brokers. For more information, see: > > &nbsp; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; http://activemq.apache.org/configuring-transports.html > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; --&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <transportConnectors&gt; > > &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;<!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB --&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <transportConnector name="default" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;amp;wireFormat.maxFrameSize=104857600"/&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </transportConnectors&gt; > > &nbsp; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <!-- destroy the spring context on shutdown to stop jetty --&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <shutdownHooks&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <bean xmlns="http://www.springframework.org/schema/beans" class="org.apache.activemq.hooks.SpringContextHook" /&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; </shutdownHooks&gt; > > &nbsp; > > &nbsp; &nbsp;&nbsp;</broker&gt; > > &nbsp; > > &nbsp;&nbsp;&nbsp; <!-- > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Enable web consoles, REST and Ajax APIs and demos > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; The web consoles requires by default login, you can disable this in the jetty.xml file > > &nbsp; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; Take a look at ${ACTIVEMQ_HOME}/conf/jetty.xml for more details > > &nbsp;&nbsp;&nbsp; --&gt; > > &nbsp;&nbsp;&nbsp; <bean id="mysql-ds" class="org.apache.commons.dbcp2.BasicDataSource" destroy-method="close"&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <property name="driverClassName" value="com.mysql.jdbc.Driver"/&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <property name="url" value="jdbc:mysql://localhost:3306/activemq?relaxAutoCommit=true"/&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <property name="username" value="xxxxx"/&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <property name="password" value="xxxxx"/&gt; > > &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <property name="poolPreparedStatements" value="true"/&gt; > > &nbsp;&nbsp;&nbsp; </bean&gt; > > &nbsp;&nbsp;&nbsp; <import resource="jetty.xml"/&gt; > > &nbsp; > > </beans&gt; > > <!-- END SNIPPET: example --&gt;