我希望能够使用Camel连续轮询数据库以从表中选择数据。我已经在我的Spring Boot应用程序中配置了Camel。这是我正在使用的配置

build.gradle:

implementation 'org.apache.camel:camel-jdbc-starter:2.24.0'

implementation 'org.apache.camel:camel-sql-starter:2.24.0'

RouteBuilder类:

@Component

public class CustomCamelConfig extends RouteBuilder {

Logger log = LoggerFactory.getLogger(getClass());

@Autowired

RouteDataMapper dataMapper;

@Override

public void configure() throws Exception {

from("timer://timer1?period=2s").log("Called every 2 seconds")

.setBody(constant("select * from tenders"))

.bean(dataMapper,"generateSalesData")

.noDelayer();

}

}

@Component

public class RouteDataMapper {

Logger log = LoggerFactory.getLogger(getClass());

public void generateSalesData(String payload) {

log.info("RouteDataMapper - [generateSalesData]");

log.info("payload : {}", payload);

}

}

application.properties

spring.datasource.driver-class-name=oracle.jdbc.driver.OracleDriver

spring.datasource.url=jdbc:oracle:thin:@xxx:xxx/zzz

spring.datasource.username=zzz

spring.datasource.password=zzz

我面临的问题是,当我打印bean方法参数(generateSalesData(字符串有效载荷))时,我得到查询字符串本身(“ select * from bids”),而不是表中的值。configure方法中的setBody()不接受sql:select .. statement,显示为“ ProcessorDefinition类型的setBody(Expression)方法不适用于参数(String)”。

我是骆驼的新手。有人可以让我知道我想念的是什么。

问题来源:Stack Overflow

apache camel 相关配置_使用apache camel从表中选择数据-问答-阿里云开发者社区-阿里云...相关推荐

  1. apache camel 相关配置_使用Apache Camel文件组件实现自定义流程策略

    迄今的尝试 h2> 我有以下启动处理的路由(名称模糊处理): @Override public void configure() throws Exception { getContext(). ...

  2. apache camel 相关配置_小白在 linux 系统部署apache、mysql、Laravel 环境学习笔记!

    在 linux 系统部署apache.mysql.Laravel 环境 一.在 CentOS 7.2 服务器下 部署 apache yum clean all --- 功能是:清除系统垃圾 yum - ...

  3. mysql云上迁移_自建mysql 迁移到云上-问答-阿里云开发者社区-阿里云

    详细解答可以参考官方帮助文档 使用 数据传输服务 DTS 可以将本地 MySQL 实例的数据迁移到 RDS for MySQL 实例.数据传输服务 DTS (以下简称 DTS) 提供的增量数据同步功能 ...

  4. 配置phoenix连接hbase_Phoenix4.14不读取hbase配置文件-问答-阿里云开发者社区-阿里云...

    cdh集群是新装的 Phoenix 4.14也是新装的 Phoenix可以建表, 可以批量导数 但就是不能建二级索引 在CM上配置如下: hbase-site.xml 的 HBase 客户端高级配置代 ...

  5. mysql数据库div函数_关于使用mysql中的div函数报错?报错-问答-阿里云开发者社区-阿里云...

    数据库MySQL 5.5.27 jar包:mysql-connector-java-5.1.21.jar mybatis-spring-1.1.1.jar druid-0.2.10.jar 集成myb ...

  6. 钉钉微应用怎么进入_钉钉微应用如何打开本地app (Android)-问答-阿里云开发者社区-阿里云...

    老李归来 2016-01-28 10:14:09 Re钉钉微应用如何打开本地app (Android)经测试,免登认证已成功,执行 dd.device.launcher.checkInstalledA ...

  7. liunx导出mysql慢查询日志查看_查看 MySQL 慢查询日志文件-问答-阿里云开发者社区-阿里云...

    查看 MySQL 是否启用了慢 SQL 查询: 查看慢 SQL 日志是否启用. mysql> show variables like 'log_slow_queries'; +--------- ...

  8. mac mysql 报错_mac os mysql 配置?报错-问答-阿里云开发者社区-阿里云

    配置mysql appledeMacBook-Pro-2:~ apple$ /usr/local/mysql-5.7.15-osx10.11-x86_64/bin/mysqladmin -u root ...

  9. nacos 本地测试_本地调试和服务器调试都无法连通-问答-阿里云开发者社区-阿里云...

    本地调试和服务器调试都无法连通 anand 2018-11-20 16:30:31 4696 异常信息: com.alibaba.nacos.api.exception.NacosException: ...

最新文章

  1. redhat enterprise linux 下配置本地yum源
  2. 芯片-模组-开发板-软件开发包SDK(Software Development Kit)的关系(软件开发人员必须了解的硬件知识)
  3. Android中Webview使用javascript调用事先定义好的Java函数
  4. mybatis3中@SelectProvider的使用技巧
  5. 设置窗口的光标,设置ToolBar,设置状态栏
  6. Netbackup设备管理之Linux篇,Netbackup设备管理之Linux篇
  7. 11.springcloud的springconfig配置
  8. python windows自动化 爬虫_Python体系(网络爬虫、人工智能、WEB开发、自动化运维)详细介绍...
  9. 9. 工作区和暂存区
  10. 从零学爬虫:采集房天下二手房信息
  11. gdb 查看是否 栈溢出_GDB调试之二栈溢出
  12. 计算机电源可调电阻,电脑ATX电源改0V-30V可调电源,电流7A
  13. Python实现决策树2(CART分类树及CART回归树)
  14. Oracle中to_date函数用法
  15. [BZOJ1776] [Usaco2010 Hol]cowpol 奶牛政坛
  16. learn opencv-使用OpenCV的自动红眼删除
  17. Aspen Plus教程-孙兰义-例7.1-质量分数求解摩尔回收率
  18. 期末复习(Day5)
  19. vs编译运行报错:未声明的标识符
  20. 《Dreamweaver CS6 完全自学教程》笔记 第十七章:Spry 框架技术

热门文章

  1. 计算机应用基础课程基本要求,计算机应用基础课程标准
  2. Pytorch cifar10离线加载二进制文件
  3. gcc/g++基本命令简介
  4. php curl 要安装pear,MacOS 安装pear
  5. yum安装odbc驱动linux,在CentOS上离线配置PostgreSQL ODBC数据源
  6. 往vxe-table添加渲染器怎么添_赚大了!飘窗上装书桌,加扇折叠窗,等于为家里又多添一间房...
  7. java开发一个完整的秒杀与竞价网上商城
  8. ppt如何旋转流程图_张伟随笔37:我书写方程式和画流程图的方法
  9. linux安装程序过程,linux 应用程序安装过程
  10. java rmi漏洞工具_学生会私房菜【20200924】Weblogic WLS核心组件反序列化命令执行突破(CVE20182628)漏洞复现...