ActivityMQ消息持久化到HANA数据库
2019独角兽企业重金招聘Python工程师标准>>>
- 在apache-activemq-5.9.0\lib中添加hana数据库驱动包ngdbc.jar
- 修改activemq.xml,添加数据连接池Bean配置
<bean id="hana-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"><property name="driverClassName" value="com.sap.db.jdbc.Driver"/><property name="url" value="jdbc:sap://192.168.23.144:30015"/><property name="username" value="WIP"/><property name="password" value="Aa123456"/>
</bean>
修改默认的kahadb配置
<persistenceAdapter><kahaDB directory="${activemq.data}/kahadb"/>
</persistenceAdapter>
改为
<persistenceAdapter><jdbcPersistenceAdapter dataSource="#hana-ds"/>
</persistenceAdapter>
- 启动MQ可能会报错,invalid column ‘XID’,查看hana数据库发现3个表已经创建,但对比表结构发现确实两个字段;所以我重新创建表,脚本如下:
CREATE TABLE ACTIVEMQ_ACKS (CONTAINER VARCHAR(250) NOT NULL,SUB_DEST VARCHAR(250),CLIENT_ID VARCHAR(250) NOT NULL,SUB_NAME VARCHAR(250) NOT NULL,SELECTOR VARCHAR(250),LAST_ACKED_ID BIGINT,PRIORITY BIGINT NOT NULL DEFAULT 5,XID VARCHAR(250)
) ;CREATE TABLE ACTIVEMQ_LOCK (ID BIGINT NOT NULL,TIME BIGINT,BROKER_NAME VARCHAR(250),CONSTRAINT "_SYS_TREE_RS_#186984_#0_#P0" PRIMARY KEY (ID)
) ;CREATE TABLE ACTIVEMQ_MSGS (ID BIGINT NOT NULL,CONTAINER VARCHAR(250),MSGID_PROD VARCHAR(250),MSGID_SEQ BIGINT,EXPIRATION BIGINT,MSG BLOB,PRIORITY BIGINT NOT NULL DEFAULT 5,XID VARCHAR(250)
) ;
CREATE INDEX ACTIVEMQ_MSGS_CIDX ON WIP.ACTIVEMQ_MSGS (CONTAINER) ;
CREATE INDEX ACTIVEMQ_MSGS_EIDX ON WIP.ACTIVEMQ_MSGS (EXPIRATION) ;
CREATE INDEX ACTIVEMQ_MSGS_MIDX ON WIP.ACTIVEMQ_MSGS (MSGID_PROD,MSGID_SEQ) ;
CREATE INDEX ACTIVEMQ_MSGS_PIDX ON WIP.ACTIVEMQ_MSGS (PRIORITY) ;
CREATE INDEX ACTIVEMQ_MSGS_XIDX ON WIP.ACTIVEMQ_MSGS (XID) ;
重新启动mq,启动成功,测试也OK!
转载于:https://my.oschina.net/u/126875/blog/1540442
ActivityMQ消息持久化到HANA数据库相关推荐
- ActiveMQ 消息持久化到Mysql数据库
修改配置文件持久化到Mysql数据库 文件路径:\conf\activemq.xml <persistenceAdapter><!--<kahaDB directory=&qu ...
- jms mysql_JMS学习九(ActiveMQ的消息持久化到Mysql数据库)
1.将连接Mysql数据库的jar文件,放到ActiveMQ的lib目录下 2.修改ActiveMQ的conf目录下的active.xml文件,修改数据持久化的方式 2.1 修改原来的kshadb的 ...
- JMS学习九 ActiveMQ的消息持久化到Mysql数据库
1.将连接Mysql数据库驱动包,放到ActiveMQ的lib目录下 2,修改ActiveMQ的conf目录下的active.xml文件,修改数据持久化的方式 2.1 修改原来的kshadb的持久化 ...
- JMS之——ActiveMQ消息持久化
转载请注明出处:http://blog.csdn.net/l1028386804/article/details/68997105 之前的几篇博文中,我们实现的ActiveMQ消息未实现消息的持久化, ...
- ActiveMQ学习笔记03 - 消息持久化
2019独角兽企业重金招聘Python工程师标准>>> ActiveMQ的消息持久化机制有JDBC,AMQ,KahaDB和LevelDB,还有一种内存存储的方式,由于内存不属于持久化 ...
- activemq消息持久化_ActiveMQ 5.x中的消息持久性
activemq消息持久化 我被问了很多关于ActiveMQ如何存储消息(或在某些情况下不存储)的基本知识. 这是它的高级解释. 注意,上下文在JMS中. 如果您使用ActiveMQ的非JMS客户端( ...
- activemq消息持久化_将ActiveMQ持久消息传递性能提高25倍
activemq消息持久化 Apache ActiveMQ,JBoss A-MQ和Red Hat Apache ActiveMQ是一个非常受欢迎的开源消息传递代理,由创建(和从事) Apache Ka ...
- rabbitmq消息队列,消息发送失败,消息持久化,消费者处理失败相关
转:https://blog.csdn.net/u014373554/article/details/92686063 项目是使用springboot项目开发的,前是代码实现,后面有分析发送消息失败. ...
- rabbitmq 持久化_RabbitMQ原理与相关操作(三)消息持久化
现在聊一下RabbitMQ消息持久化: 问题及方案描述 1.当有多个消费者同时收取消息,且每个消费者在接收消息的同时,还要处理其它的事情,且会消耗很长的时间.在此过程中可能会出现一些意外,比如消息接收 ...
最新文章
- 如何设置鼠标移开后css,如何设置鼠标离开时由hover设置的样式不变?
- java sort算法名称_快速排序算法(Quick Sort)(java)
- C++Builder Berlin 编译
- 深入分析ReentrantLock公平锁和非公平锁的区别 (转)
- opensuse13.2 安裝五笔
- VS2008工程转为VS2005(C++)
- 红黑树的理解与 Java 实现
- 电脑基础操作_在东莞大朗,学习电脑办公软件,就要找这样的学校!
- 从原理上理解MySQL的优化建议
- c语言编程被当作病毒,为什么这个微不足道的C程序被检测为病毒?
- 栈溢出笔记1.7 地址问题(2)
- [转载] python字符串_一文详解Python字符串条件判断方法
- 《番茄工作法图解》一次只做一件事
- VISIO使用FPGA时序图、状态机等所需的模具
- python卡方拟合性检验_卡方拟合优度检验
- css3实现椭圆轨迹运动
- python爬虫|post的响应,利用python实现有道翻译在线翻译
- Arduino库的接口:Ticker库
- 正则表达式输入框验证正整数、负整数、小数点
- [CVPR 2020] D3Feat: Joint Learning of Dense Detection and Description of 3D Local Features