u010990595
ffej
2010-03-19 13:29

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

已采纳

想将activeMQ消息持久化到数据库中,网上都是说将activeMQ.xml文件做如下设置:








我能否在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代码如何设置消息持久化到数据库中?什么教程有这方面的说明吗?您可以帮忙解答一下吗?不胜感激!

  • 点赞
  • 写回答
  • 关注问题
  • 收藏
  • 复制链接分享
  • 邀请回答

4条回答

  • amandalv amandalv 11年前

    activeMQ本身就随开机启动 不需要在代码中嵌套启动
    打开我的电脑->服务 打开activemq服务
    如图 服务的路径明确
    [img]http://photo.163.com/loeki@126/big/#aid=198873777&id=5855063434[/img]

    则意味着可以在D:\apache-activemq-5.2.0\bin 里activemq.xml文件中进行配置,与数据库进行持久化

    Producer 设置persistent 发送消息 关闭eclipse shutdown机器 运行consumer 仍然能收到刚刚producer发送的消息——持久化实现!(但是没有改变activemq.xml)

    应该是存在eclipse里的activemq-data文件夹里了

    点赞 评论 复制链接分享
  • iteye_13500 iteye_13500 11年前

    [quote]那请问apache的论坛是什么?能给个地址吗?是国外的吗?谢谢[/quote]

    http://activemq.apache.org/discussion-forums.html

    进入

    ActiveMQ User Forum

    点赞 评论 复制链接分享
  • iteye_13500 iteye_13500 11年前

    [quote]我能否在java代码中进行设置呢?因为我是在eclipse中导入的activemq-all-5.2.0.jar包,开发的系统,包中没有activemq.xml文件。而且时间比较紧,我没有用spring。 而且我是把broker嵌入在eclipse中启动的,代码如下: [/quote]

    恩,你的使用情况我也是头一次听到,提供一种思路吧,可以试试,不一定行:
    你可以把activemq-all-5.2.0.jar解包,然后把activemq.xml放进去(可以放在根目录和META-INF目录都试一下),再重新打成jar包。看看是否在生成BrokerService的时候自动加载这个文件。

    另外,这个问题感觉去apache的论坛上问比较好。

    点赞 评论 复制链接分享
  • wanghaolovezlq wanghaolovezlq 11年前