码迷,mamicode.com
首页 > 数据库 > 详细

ActiveMQ(5.10.0) - 使用 JDBC 持久化消息

时间:2015-08-27 15:08:16      阅读:166      评论:0      收藏:0      [点我收藏+]

标签:

1. 编辑 ACTIVEMQ_HOME/conf/activemq.xml。

<beans>
    <broker brokerName="localhost" persistent="true" xmlns="http://activemq.apache.org/schema/core">
        <persistenceAdapter>
            <jdbcPersistenceAdapter dataSource="#mysql-ds" useDatabaseLock="false" transactionIsolation="4"/>
        </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/activemq?relaxAutoCommit=true"/>
        <property name="username" value="activemq"/>
        <property name="password" value="activemq"/>
        <property name="maxActive" value="200"/>
        <property name="poolPreparedStatements" value="true"/>
    </bean>
</beans>

2. 在 ACTIVEMQ_HOME/lib 目录或其子目录下添加相应数据库的驱动包。

3. 启动 activemq,在指定的数据库会自动创建三张表:activemq_msgs、activemq_acks、activemq_lock。

 

ActiveMQ(5.10.0) - 使用 JDBC 持久化消息

标签:

原文地址:http://www.cnblogs.com/huey/p/4763135.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!