作者:没有丝袜姑娘 | 来源:互联网 | 2023-10-10 16:23
本demo是将msg持久化到oracle数据库
需要在ActiveMQ中加入jdbc依赖的jar包,实测用到的jar包有:
- commons-pool-1.5.4.jar
- commons-dbcp-1.4.jar
- ojdbc14-10.2.0.4.0.jar
将这三个jar包下载后复制到activeMQ的conf包lib下
修改activeMQ.xml文件
替换已有的persisitenceAdapter
在broker标签外加入配置:
配置完成之后 启动acticeMQ 你会发现数据库多了三张表
select * from activemq_acks;
select * from activemq_locks;
select * from activemq_msgs;
当activeMQ接收到消息时会在activeMQ_msgs表中插入一条数据
当有consumer将该消息消费掉之后 mq会自动删除activeMQ_msgs那表中的数据