1.首先需要把MySql的驱动放到ActiveMQ的Lib目录下，我用的文件名字是：mysql-connector-Java-5.1.30-bin.jar

注意：MQ支持的MySQL版本比较低，所以这里用的是低版本 >mysql-connector-Java-5.1.30

2.

 修改配置文件activemq.xml

将其中的这段配置：

<persistenceAdapter>

<kahaDB directory="${activemq.base}/data/kahadb"/>

</persistenceAdapter>

修改为下面这段内容：

<persistenceAdapter>

         <jdbcPersistenceAdapter  dataSource="#MySQL-DS"/>

</persistenceAdapter>

3、配置MySQL数据源：在</broker>节点后面，增加MySQL数据源配置：

    <!-- MySQL DataSource -->

<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://127.0.0.1:3306/testmq?useUnicode=true&amp;characterEncoding=UTF-8"/>

    <property name="username" value="root"/>

    <property name="password" value="123456"/>

    <property name="poolPreparedStatements" value="true"/>

</bean>