You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by "ヤ艾枫o.--" <11...@qq.com.INVALID> on 2023/06/27 08:00:10 UTC
回复： 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
Same as using the latest version, there is no data in the ACTIVEMQ_LOCK.
Is the configuration file missing content
ヤ艾枫o.--
1169114186@qq.com
------------------ 原始邮件 ------------------
发件人: "users" <mattrpav@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.-- <1169114186@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;
回复： 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
Posted by "ヤ艾枫o.--" <11...@qq.com.INVALID>.
thanks for your idea. Add this config , The table ACTIVEMQ_LOCK has data.
In addition, I am using a higher version of MySQL (8.0) and without the configuration you mentioned, I can also complete master-slave switching, but There is still no data in the ACTIVEMQ_LOCK table. The previously used MySQL 5.7 version resulted in no data in the table and unable to complete the switch.
Now my question is, if I use ActiveMQ5.18.1, which version of MySQL should I use? 5.7 or 8.0。Is there a dependency relationship
ヤ艾枫o.--
1169114186@qq.com
------------------ 原始邮件 ------------------
发件人: "users" <mattrpav@gmail.com>;
发送时间: 2023年6月27日(星期二) 晚上9:48
收件人: "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
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.-- <1169114186@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.--
> 1169114186@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" <mattrpav@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.-- <1169114186@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;
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
Posted by Matt Pavlovich <ma...@gmail.com>.
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.-- <11...@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.--
> 1169114186@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" <ma...@gmail.com>;
> 发送时间: 2023年6月27日(星期二) 凌晨3:21
> 收件人: "users@activemq.apache.org"<us...@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.-- <11...@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 -->