ActiveMQ(5.10.0) - 使用 JDBC 持久化消息
时间：2021-07-01 10:21:17
帮助过：5人阅读
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 持久化消息
标签：
