一 、修改数据存放数据源
<persistenceAdapter>
<!-- <kahaDB directory="${activemq.data}/kahadb"/> -->
<jdbcPersistenceAdapter dataSource="#mysql-ds" useDatabaseLock="false"/>
</persistenceAdapter>
二 </broker>下方配置
<bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
<property name="url" value="jdbc:mysql://localhost:3306/Test?useUnicode=true&characterEncoding=utf-8&useSSL=false&relaxAutoCommit=true"/>
<property name="username" value="root"/>
<property name="password" value="12345678"/>
<property name="maxActive" value="200"/>
<property name="poolPreparedStatements" value="true"/>
</bean>
三拷贝mysql-connector-java-8.0.19.jar commons-dbcp-1.4.jar 以及commons-pool-1.6.jar到 mq的 lib下
遇到的问题:
1 nested exception is java.lang.ClassNotFoundException: org.apache.commons.dbcp.BasicDataSource
拷贝commons-dbcp-1.4.jar 以及commons-pool-1.6.jar到 mq的 lib下
2