ActiveMq 訊息持久化到MySql資料庫

1、修改 conf/activemq.xml配置檔案

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

將預設的配置改成

<persistenceAdapter>
    <jdbcPersistenceAdapter dataSource="#my-ds"/>
</persistenceAdapter>

2、新增bean配置

    <bean id="my-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?useUnicode=true&amp;characterEncoding=UTF-8
 
" />
        <property name="username" value="username" />
        <property name="password" value="password" />
        <property name="maxTotal" value="100" />
        <property name="poolPreparedStatements" value="true"/>
    </bean>

3、新增資料

4、重新啟動服務