我想要得到第一行的大文件。choice().when(simple("${property.CamelSplitIndex} == 0")).log("header month :: ${body}").endChoice()
这是我的第一行，但问题是拆分器还在继续处理其他记录，这会影响我的等待时间、cpu和内存。所以，无论如何我可以读取第一
浏览 14提问于2020-05-18得票数 1
我有一个Apache Camel路由，它的目的是获取xml文档和文档中链接的文件。password=xxx&include=.*.xml"/> </route>
当它到达myBean时，我希望解析该文件，并使用相同的ftp设置来获取xml-file中列出的
浏览 2提问于2017-08-21得票数 0
1回答
我是Camel新手，我想使用它来读取FTP服务器上的XML文件，以及XML的所有节点元素的assynch进程。然后是到nodeProcessor的路径： .bean(lookup(MyNodeProcessor.class))
.end<
浏览 6提问于2015-07-10得票数 1
回答已采纳
2回答
我有一个Camel路由，它需要作为流从FTP接收XML文件，验证它并分割它。在这种情况下，我可以看到Exchange进入拆分器，但是没有找到处理器，并且拆分什么也做不到。();
在这种情况下，拆分器可以正常工作。另外，如果XML文件不是来
浏览 4提问于2015-08-05得票数 0
回答已采纳
1回答
使用Camel拆分一个ArrayList并并行处理每一项最多10个线程。下面是配置。线程池配置文件设置为最大线程计数=10。method=getPendingTransactions获取ArrayList并传递给拆分器。
processReportChannel是处理项的处理器。问题:当作业开始时，正在启动10个线程，但是一些线程正在拾取相同的项。例如，如果我在item_no_1中使用ArrayList、thread
浏览 3提问于2014-11-05得票数 1
我有一个处理csv文件并将它们作为记录插入到数据库中的路由。由于它是一个巨大的csv文件，而Camel csv-splitter耗尽了内存，我们不得不编写我们自己的拆分器。我使用ProducerTemplate编写了拆分器。method=process"/>在csvBean中，我们进行拆分，最后对
浏览 3提问于2012-11-18得票数 0
1回答
我正在解析一个CSV文件，将其拆分并通过camel中的多个处理器进行路由。有两个端点，一个具有错误数据，而另一个具有验证数据。
我需要在聚合数据方面的建议。假设CSV文件有10条记录，其中6条到达一个端点，4条到达另一个端点。我如何才能知道每个端点的文件中的所有10个都已完成，并领先于聚合器。我需要创建两个文件，一个包含有效数据，另一个包含来自单
浏览 1提问于2014-10-14得票数 3
回答已采纳
2回答
我在spring中定义了以下路由，用于拆分文本文件中的行，并将每一行发送到JMS队列上面的路由可以在没有错误的情况下运行，但是从文件中分离出来的行不会以JMS消息
浏览 3提问于2015-07-27得票数 1
回答已采纳
我的问题是(1)有没有更好的策略来解决我的问题(2)有没有可能调整/改进我的解决方案，使它能够工作，并且不会以可靠的方式拆分聚合(3 )如何更智能地调试它？我正在编写一条路径，以消化一百万行的CSV文件，拆分然后聚合一些主要关键字段上的数据，然后将聚合的记录写入一个表
对于几千条记录的小文件，它工作得很好，但在生产中实际面临的大<em
浏览 1提问于2013-02-24得票数 1
回答已采纳
嗨，我刚接触Java，camel等。这是我的问题：目前，这个处理器使用ProducerTemplate来显式地完成这一任务。我已经看过了拆分器<
浏览 3提问于2014-05-24得票数 0
是否有一种简单的方法可以跳过csv头的第一行，使用camel EIP拆分器处理所有其他行并聚合所有行(包括跳过的行)？我需要转换CSV文件中每个记录的日期，但是跳过第一行，即头。我在试着用骆驼EIP分离器。谢谢!
浏览 3提问于2018-04-11得票数 1
回答已采纳
我正在尝试执行一个文件导入过程，其中在给定文件夹的子目录中选取一个文件，该子目录标识该文件所针对的客户端，然后对记录进行解析、拆分，并将其发送到Hazelcast SEDA队列。我希望在从Hazelcast SEDA队列中读取每个记录时对其进行处理，然后它将返回一个状态代码(已创建、已更新或已出错)，该状态代码可以聚合。在第一次拾取文件时，我还创建了一个作业记录，并希望使用创建、更新和错误的最终计数
浏览 2提问于2017-09-28得票数 1
我是activeMQ / Camel的新手，所以请容忍我。
在驼峰路由中，我使用拆分器来生成多个子路由。这些路由中的每一个都将使用一些外部API来做一些工作，并进行轮询，直到工作完成。我就差那么远。现在，我需要触发最后一个操作来收集所有这些路由的结果。我该如何使用Camel / AMQ的方式呢？我正在考虑将每个子路由中的一条消息发送到一个AMQ队列，但我还没有找到一种方法，在我的最后一个C
浏览 1提问于2020-02-03得票数 0
我有一个xml，在这个xml中，我使用split标记在Spring中进行处理。我所做的基本上是在xml中搜索一个值，当我找到这个值时，我需要获得另一个标记的值，该标记是同一个元素的子元素，并保存到一个标头中。这个操作看起来很简单，但是我无法在split之外恢复我的头，所以我需要恢复。我尝试使用标头和属性，结果是一样的。代码示例：...
浏览 3提问于2014-09-01得票数 2
我有一个简单的路线，从FTP服务器轮询压缩文件。zip文件由一个需要处理的文件和零或多个附件组成。我试图使用ZipFileDataFormat进行拆分，并且能够按需要拆分和路由项目，即将处理文件发送到处理器，并将其他文件发送到聚合器端点。header.CamelSplitComplete}")
.log("Split Size
浏览 2提问于2017-06-29得票数 1
回答已采纳
我试图在Camel路由中构建一个使用REST端点的拆分/聚合模式。它接受包含请求详细信息列表的请求对象。我希望并行处理请求细节，然后将聚合结果返回给调用方。我希望这是一个同步调用。这是我路线上的密码。5000L).parallelProcessing() .end(我的响应对象)
浏览 6提问于2014-08-28得票数 3
根据，在Camel 2.3或更高版本中，拆分器应该返回原始消息。我们使用的是2.13.2，但在拆分()之后，身体似乎是最后一个拆分消息(即为Camel 2.2描述的行为)。.to(ExchangePattern.InOnly, IMPORT_QUEUE_ENDPOINT_URI) .end整个输入消息被验证(webServiceVali
浏览 7提问于2014-09-17得票数 0
回答已采纳
从使用camel的春季引导中，我想知道是否有可能在骆驼路线完成后(在我的示例中的最后一条路径)获得来自骆驼路由的响应。start") .split().body().to("direct:actionQueue")
.endCollected validations: "+collec
浏览 2提问于2016-09-15得票数 0
回答已采纳
我的路线在骆驼下面。.log(LoggingLevel.ERROR, "ENRICHMENT-EXCEPTION : ${exception.stacktrace}") .end()// End of split() and parallelProcessing()但是在我下面的聚合中，我得到了n
浏览 0提问于2019-05-16得票数 0
回答已采纳
exrate.put(m.group(1), Integer.parseInt(m.group(2))); return exrate.entrySet();}[org.apache.camel.processor.DefaultErrorHandler] : Redelivery enabled: false on error handler: DefaultErrorHandler(Object
浏览 2提问于2016-01-05得票数 1
回答已采纳
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
