ActiveMQ持久化消息的三种方式

<persistenceAdapter>

<kahaDBdirectory="${activemq.base}/data/kahadb"/>


</persistenceAdapter>


producer.Send(request, MsgDeliveryMode.Persistent, level, TimeSpan.MinValue);

<persistenceAdapter>

<jdbcPersistenceAdapterdataDirectory="${activemq.base}/data"dataSource="#derby-ds"/>

</persistenceAdapter>

<bean id="derby-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">

<propertyname="driverClassName"value="com.mysql.jdbc.Driver"/>


<propertyname="url"value="jdbc:mysql://localhost/activemq?relaxAutoCommit=true"/>


<propertyname="username"value="activemq"/>


<propertyname="password"value="activemq"/>


<propertyname="maxActive"value="200"/>


<propertyname="poolPreparedStatements"value="true"/>

</bean>

<bean id="derby-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">

<propertyname="driverClassName"value="oracle.jdbc.driver.OracleDriver"/>


<propertyname="url"value="jdbc:oracle:thin:@10.53.132.47:1521:cmfudv1"/>


<propertyname="username"value="qdcommu"/>


<propertyname="password"value="qdcommu"/>


<propertyname="maxActive"value="200"/>


<propertyname="poolPreparedStatements"value="true"/>

</bean>