日期:2014-05-16  浏览次数:20487 次

Activemq持久化消息到MySql数据库中

1.添加MySql数据源

????? ?打开Activemq安装目录下的conf/activemq.xml文件,添加MySql数据源。默认情况下Activemq使用KahaDB存储,注解掉KahaDB配置,改为mysql配置如下:

?

<!--
<persistenceAdapter>
??? <kahaDB directory="${activemq.base}/data/kahadb"/>
</persistenceAdapter>
-->
<persistenceAdapter>
???
<jdbcPersistenceAdapter dataSource="#MySQL-DS"/>
</persistenceAdapter>

?

该配置表示,我们将要使用名称为“MySQL-DS”的作为mysql数据源。

2. 配置MySql数据源

????? 在</broker>节点后面,增加MySQL数据源配置:

?

<!-- MySQL DataSource -->
<bean id="MySQL-DS" class="org.apache.commons.dbcp.BasicDataSource" destroy-ethod="close">
???
<property name="driverClassName" value="com.mysql.jdbc.Driver"/>
???
<property name="url" value="jdbc:mysql://127.0.0.1:3306/activemq?relaxAutoCommit=true"/>
???
<property name="username" value="用户名"/>
???
<property name="password" value="登录密码"/>
???
<property name="poolPreparedStatements" value="true"/>
</bean>

?

此处