如何配置spring与activeMQ持久性消息存储数据库? (Spring Framework|逻辑层) - [Matrix - 与 Java 共舞]

<beans
xmlns="http://www./schema/beans"
xmlns:xsi="http://www./2001/XMLSchema-instance"
xmlns:amq="http:///config/1.0"
xsi:schemaLocation="http://www./schema/beans http://www./schema/beans/spring-beans-2.0.xsd
http:///config/1.0 http://people./repository/org.apache.activemq/xsds/activemq-core-4.1-SNAPSHOT.xsd">

<!-- lets create an embedded ActiveMQ Broker -->
<amq:broker useJmx="false" persistent="true">
<amq:persistenceAdapter>
<amq:jdbcPersistenceAdapter id="jdbcAdapter" dataSource="#msgDataSource" createTablesOnStartup="true"
useDatabaseLock="false"/>
</amq:persistenceAdapter>
<amq:transportConnectors>
<amq:transportConnector uri="tcp://localhost:0"/>
</amq:transportConnectors>
</amq:broker>

<!-- The Sybase Datasource that will be used by the Broker and Hibernate -->
<bean id="msgDataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
<property name="driverClassName" value="com.sybase.jdbc2.jdbc.SybDriver"/>
<property name="url" value="jdbc:sybase:Tds:192.168.1.1:2659/msgdb"/>
<property name="username" value="dba"/>
<property name="password" value="sql"/>
<property name="poolPreparedStatements" value="true"/>
</bean>
<!-- ActiveMQ destinations to use -->
<amq:queue id="destination" physicalName="org.apache.activemq.spring.Test.spring.embedded"/>

<!-- JMS ConnectionFactory to use, configuring the embedded broker using XML -->
<amq:connectionFactory id="jmsFactory" brokerURL="vm://localhost"/>

<!-- Spring JMS Template -->
<bean id="myJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory">
<!-- lets wrap in a pool to avoid creating a connection per send -->
<bean class="org.springframework.jms.connection.SingleConnectionFactory">
<property name="targetConnectionFactory">
<ref local="jmsFactory"/>
</property>
</bean>
</property>
<property name="defaultDestination">
<ref local="destination"/>
</property>
<property name="messageConverter" ref="messageConverter"/>
</bean>

<bean id="messageConverter" class="com.dlkysoft.activemq.MBMessageConverter"/>

<bean id="consumerJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
<property name="connectionFactory" ref="jmsFactory"/>
</bean>
</beans>