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