骆驼投票Enrich JPA忽略namedQuery
与JPA Consumer、transform和其他中间路线操作一起制作骆驼ETL路线的示例。这包括针对另一个JPA实体的额外步骤。PollRich步骤应该基于定义的带动态参数的namedQuery（通过先前交换中的#params注册表映射传递）来使用实体数据。它完全忽略namedQuery。它也会忽略任何在线查询——不管查询有多简单——并简单地将初始记录轮询到maximumResults。
from("jpa:com.tcfbank.example.entity.PersonEntity?maxMessagesPerPoll=500&persistenceUnit=cedb&consumer.namedQuery=withOccupationCodeAndValidIdentification&consumer.initialDelay=3000&delay=3000&consumeDelete=false&consumeLockEntity=false")
.convertBodyTo(CanonicalPerson.class)
.to("bean:parameterManager")
.pollEnrich("jpa:com.tcfbank.example.entity.AccountEntity?persistenceUnit=cedb2&consumer.resultClass=com.tcfbank.example.entity.AccountEntity&consumer.namedQuery=byCustomerId&consumer.parameters=#params&consumeDelete=false&consumeLockEntity=false&maximumResults=50", 5000, "accountAggregationStrategy").id("EnrichWithAccounts")
.to("bean:scoringClient")
.setHeader(Exchange.FILE_NAME, el("${in.body.customerId}.xml"))
.to("file:target/customers");
共有1个答案
PolleEnrich不是一个jpaonsuer，而是一个污染消费者，从参数中删除前缀消费者
.pollEnrich("jpa:com.tcfbank.example.entity.AccountEntity?persistenceUnit=cedb2&<strike>consumer.</strike>resultClass=com.tcfbank.example.entity.AccountEntity&<strike>consumer.</strike>namedQuery=byCustomerId&<strike>consumer.</strike>parameters=#params&consumeDelete=false&consumeLockEntity=false&maximumResults=50", 5000, "accountAggregationStrategy").id("EnrichWithAccounts")
-
无法弄清楚这是怎么回事-试图设置一个路由，只看到cxf连接到soap web服务（我不关心实际数据，也不期望数据实际“工作”，但它不断引发一个我不理解的异常： 我想知道我是否正确配置了它。我想这可能是一个丢失的jar，但当我尝试引入其他jar时，导致了依赖冲突 我正在使用maven依赖项“camel-cxf”来加载我所有的jar配置 “原因：org.apache.cxf.bus.extension
-
一、简介 系统的投票功能提供了两种投票类型,第一个是单选投票.第二种是多选投票.网站编辑人员可以根据实际的需求,选择类型进行操作。 何处使用投票： 常用于首页、内容页、及专题页面。所有你想放投票的区域。 如何使用： 只需要根据投票所放位置不同，复制对应代码到模版里即可。 系统信息发布页 和 专题管理内置提供了投票选择功能，只需手动点选，即可添加投票。 针对不同位置CSS样式不同，系统提供了三种常用
-
现在我们的系统更完善了，但是想要找到最受欢迎的帖子有点难。我们需要一个排名系统来给我们的帖子排个序。 我们可以建立一个基于 karma 的复杂排名系统，权值随着时间衰减，和许多其他因素（很多功能都在 Telescope 中实现了，他是 Microscope 的大哥）。但是对于我们的例子 app, 我们尽量保持简单，我们只按照帖子收到的投票数为它们排序。 让我们实现一个给用户为帖子投票的方法。 数据
-
获取投票信息 Mudu.Room.Vote.Get(function (response) { response = JSON.parse(response) if (response.status === 'y') { console.log('获取成功，数据为：', response.data) } if (response.status === 'n') {
-
我们正在尝试使用Apache Camel进行集群。到目前为止，我们在一个节点上完成了它，并且工作得很好。 一个节点：我将readlock策略设置为“changed”，它将跟踪camelLock文件的文件变化，并且只有当文件下载完成时，它才会被拿起进行处理。但是camel readlock策略“已改变”在聚类中是不鼓励的。根据camel文档，建议使用“幂等”。这就是我使用5GB文件进行测试时所发生的
-
我正在使用带有Apache骆驼的Spring Boot。我正在从控制器调用路由。一旦路由完成，控制就会返回控制器。我正在VerifyLimitProcess和批准限制处理器中生成响应。如果我没有在路由中提供窃听配置，控制器会按预期检索标头和正文。但如果我在路由中引入窃听，控制器会将标头和正文接收为null。如果有人指出我需要做什么，以便我可以在选择语句中引入两个处理器的窃听配置，即VerifyLi