如何使用bean配置啓用ActiveMQ嵌入式kahadb

我需要通過啓用kahadb來啓用activemq嵌入式代理的本地持久性。我如何在bean xml文件中配置kahadb。如何使用bean配置啓用ActiveMQ嵌入式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的默認持久db是kahoDb。這行<property name="persistent" value="true"/>做了這個。我需要知道如何改變這個數據庫到另一個。此外，我需要一個很好的參考來爲activemq配置spring xml文件？

來源

2015-06-01 Burusothman

KahaDB是默認存儲在持久性= true，所以你需要提供什麼你正在嘗試一些更多信息完成和什麼沒有爲你工作 –

@Tim Bish剛剛檢查了activemq的默認數據庫是kahaDB。在發送消息時，我的錯誤是producer.setDeliveryMode（DeliveryMode.NON_PERSISTENT）。如何設置這個默認的數據庫到其他數據庫（顯然我需要很好的參考學習activemq春季XML描述） – Burusothman

您可以創建一個org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter豆，並通過persistenceAdapter屬性將其注入您的經紀商。

E.g.

<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

來源

2015-06-01 12:44:05 hemant1900

如何使用bean配置啓用ActiveMQ嵌入式kahadb

回答

相關問題