想将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代码如何设置消息持久化到数据库中?什么教程有这方面的说明吗?您可以帮忙解答一下吗?不胜感激!
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文件夹里了
参考消息持久化配置
http://extrimlycold20070206121610.iteye.com/blog/511321
http://zhaiyl.spaces.live.com/blog/cns!939A197D2798715B!125.entry
[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的论坛上问比较好。
[quote]那请问apache的论坛是什么?能给个地址吗?是国外的吗?谢谢[/quote]
http://activemq.apache.org/discussion-forums.html
进入
ActiveMQ User Forum