我希望能夠使用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从表中选择数据-问答-阿里云开发者社区-阿里云...的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。