用java代码如何设置activemq消息持久化到数据库中?

吕奕 发布于 2010/03/20 10:36
阅读 2K+
收藏 0

想将activeMQ消息持久化到数据库中,网上都是说将activeMQ.xml文件做如下设置:
<persistence>
      <jdbcPersistence dataSourceRef=" mysql-ds"/>
</persistence>

<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/activemq?relaxAutoCommit=true"/>
      <property name="username" value="activemq"/>
      <property name="password" value="activemq"/>
      <property name="poolPreparedStatements" value="true"/>
</bean>

我能否在java代码中进行设置呢?因为我是在eclipse中导入的activemq-all-5.2.0.jar包,开发的系统,包中没有activemq.xml文件。而且时间比较紧,我没有用spring。 而且我是把broker嵌入在eclipse中启动的,代码如下:
BrokerService broker = new BrokerService();
broker.setUseJmx(true);
  
  broker.setBrokerName(brokerName);
  broker.addConnector("tcp://localhost:61616");
  broker.start();

用java代码如何设置消息持久化到数据库中?什么教程有这方面的说明吗?您可以帮忙解答一下吗?不胜感激!

加载中
返回顶部
顶部