2019独角兽企业重金招聘Python工程师标准>>>

  1. 在apache-activemq-5.9.0\lib中添加hana数据库驱动包ngdbc.jar
  2. 修改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>
  1. 启动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数据库相关推荐

  1. ActiveMQ 消息持久化到Mysql数据库

    修改配置文件持久化到Mysql数据库 文件路径:\conf\activemq.xml <persistenceAdapter><!--<kahaDB directory=&qu ...

  2. jms mysql_JMS学习九(ActiveMQ的消息持久化到Mysql数据库)

    1.将连接Mysql数据库的jar文件,放到ActiveMQ的lib目录下 2.修改ActiveMQ的conf目录下的active.xml文件,修改数据持久化的方式 2.1  修改原来的kshadb的 ...

  3. JMS学习九 ActiveMQ的消息持久化到Mysql数据库

    1.将连接Mysql数据库驱动包,放到ActiveMQ的lib目录下 2,修改ActiveMQ的conf目录下的active.xml文件,修改数据持久化的方式 2.1  修改原来的kshadb的持久化 ...

  4. JMS之——ActiveMQ消息持久化

    转载请注明出处:http://blog.csdn.net/l1028386804/article/details/68997105 之前的几篇博文中,我们实现的ActiveMQ消息未实现消息的持久化, ...

  5. ActiveMQ学习笔记03 - 消息持久化

    2019独角兽企业重金招聘Python工程师标准>>> ActiveMQ的消息持久化机制有JDBC,AMQ,KahaDB和LevelDB,还有一种内存存储的方式,由于内存不属于持久化 ...

  6. activemq消息持久化_ActiveMQ 5.x中的消息持久性

    activemq消息持久化 我被问了很多关于ActiveMQ如何存储消息(或在某些情况下不存储)的基本知识. 这是它的高级解释. 注意,上下文在JMS中. 如果您使用ActiveMQ的非JMS客户端( ...

  7. activemq消息持久化_将ActiveMQ持久消息传递性能提高25倍

    activemq消息持久化 Apache ActiveMQ,JBoss A-MQ和Red Hat Apache ActiveMQ是一个非常受欢迎的开源消息传递代理,由创建(和从事) Apache Ka ...

  8. rabbitmq消息队列,消息发送失败,消息持久化,消费者处理失败相关

    转:https://blog.csdn.net/u014373554/article/details/92686063 项目是使用springboot项目开发的,前是代码实现,后面有分析发送消息失败. ...

  9. rabbitmq 持久化_RabbitMQ原理与相关操作(三)消息持久化

    现在聊一下RabbitMQ消息持久化: 问题及方案描述 1.当有多个消费者同时收取消息,且每个消费者在接收消息的同时,还要处理其它的事情,且会消耗很长的时间.在此过程中可能会出现一些意外,比如消息接收 ...

最新文章

  1. 如何设置鼠标移开后css,如何设置鼠标离开时由hover设置的样式不变?
  2. java sort算法名称_快速排序算法(Quick Sort)(java)
  3. C++Builder Berlin 编译
  4. 深入分析ReentrantLock公平锁和非公平锁的区别 (转)
  5. opensuse13.2 安裝五笔
  6. VS2008工程转为VS2005(C++)
  7. 红黑树的理解与 Java 实现
  8. 电脑基础操作_在东莞大朗,学习电脑办公软件,就要找这样的学校!
  9. 从原理上理解MySQL的优化建议
  10. c语言编程被当作病毒,为什么这个微不足道的C程序被检测为病毒?
  11. 栈溢出笔记1.7 地址问题(2)
  12. [转载] python字符串_一文详解Python字符串条件判断方法
  13. 《番茄工作法图解》一次只做一件事
  14. VISIO使用FPGA时序图、状态机等所需的模具
  15. python卡方拟合性检验_卡方拟合优度检验
  16. css3实现椭圆轨迹运动
  17. python爬虫|post的响应,利用python实现有道翻译在线翻译
  18. Arduino库的接口:Ticker库
  19. 正则表达式输入框验证正整数、负整数、小数点
  20. [CVPR 2020] D3Feat: Joint Learning of Dense Detection and Description of 3D Local Features

热门文章

  1. 下载ssl证书并安装后如何导出备份
  2. 2、Ktor学习-自动重新加载;
  3. SQL server 2005中无法新建作业(Job)的问题
  4. jquery-1.4.4.min.js无法解析json中result.data问题
  5. 层次建模---建模软件包
  6. 云安全云计算 迷团大揭幕
  7. 如何让EasyUI弹出层跳出框架
  8. PostgreSql安装(win 2003 下)
  9. 【翻译】Programming Ruby——正则表达式
  10. 架构师之路 — 分布式系统 — 分布式事务难题