java - 如何使用 bean 配置启用 ActiveMQ 嵌入式 kahadb

Question

我需要通过启用 kahadb 来启用 activemq 嵌入式代理的本地持久性。我如何在 bean xml 文件中配置 kahadb。

<bean id="producerBroker" class="org.apache.activemq.broker.BrokerService" init-method="start" destroy-method="stop">

        <property name="brokerName" value = "producerBroker"/>
        <property name="persistent" value="true"/>
        <property name="transportConnectorURIs">
            <list>
                <value>tcp://localhost:7005</value>
            </list>
        </property>
        <property name="jmsBridgeConnectors">
            <list>
                <bean class="org.apache.activemq.network.jms.JmsQueueConnector">
                    <property name="outboundQueueConnectionFactory">
                        <bean class="org.apache.activemq.ActiveMQConnectionFactory">
                            <property name="brokerURL" value="http://localhost:8090" />
                        </bean>
                    </property>
                    <property name="outboundQueueBridges">
                        <list>
                            <bean class="org.apache.activemq.network.jms.OutboundQueueBridge">
                                <constructor-arg value="qvsample"/>
                            </bean>
                        </list>
                    </property>
                </bean>
            </list>
        </property>
    </bean>

编辑

ActiveMQ 默认的持久化数据库是 kahoDb。这条线 <property name="persistent" value="true"/>做了这个。我需要知道如何将此数据库更改为另一个数据库。此外，我需要一个很好的引用来为 activemq 配置 spring xml 文件吗？

Answer 1

您可以创建一个 org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter 的 bean，并通过 persistenceAdapter 属性将其注入(inject)您的代理。

例如

<bean id="persistenceAdapter" class="org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter">
    <property name="directory" value="D:\test"/>
</bean>

<bean id="producerBroker" class="org.apache.activemq.broker.BrokerService" init-method="start" destroy-method="stop">
    <property name="persistenceAdapter" ref="persistenceAdapter"/>
</bean>

您可以使用任何其他持久化适配器(例如 leveldb)，只要它实现了 org.apache.activemq.store.PersistenceAdapter