activemq 数据持久化mysql

CREATE DATABASE activemq;
USE activemq;

CREATE TABLE queue (
    id BIGINT AUTO_INCREMENT PRIMARY KEY,
    message_id VARCHAR(255) NOT NULL,
    message TEXT NOT NULL,
    expiration BIGINT,
    inserted TIMESTAMP DEFAULT CURRENT_TIMESTAMP
);

<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost" dataDirectory="${activemq.data}">

    <destinationPolicy>
        <policyMap>
            <policyEntries>
                <policyEntry queue=">" producerFlowControl="true" optimizedDispatch="true" maxPageSize="200" maxBrowsePageSize="200" />
            </policyEntries>
        </policyMap>
    </destinationPolicy>

    <persistenceAdapter>
        <jdbcPersistenceAdapter dataSource="#mysql-ds" createTablesOnStartup="true" />
    </persistenceAdapter>

    <systemUsage>
        <systemUsage>
            <memoryUsage>
                <memoryUsage percentOfJvmHeap="70" />
            </memoryUsage>
            <storeUsage>
                <storeUsage limit="10 gb"/>
            </storeUsage>
            <tempUsage>
                <tempUsage limit="5 gb"/>
            </tempUsage>
        </systemUsage>
    </systemUsage>

    <plugins>
        <simpleAuthenticationPlugin>
            <users>
                <authenticationUser username="admin" password="admin" groups="admins,publishers,consumers"/>
            </users>
        </simpleAuthenticationPlugin>
    </plugins>

    <transportConnectors>
        <transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&amp;wireFormat.maxFrameSize=104857600"/>
    </transportConnectors>

    <dataSources>
        <dataSource id="mysql-ds" driverClassName="com.mysql.jdbc.Driver" url="jdbc:mysql://localhost:3306/activemq" username="root" password="password" maxActive="20"/>
    </dataSources>

</broker>