-
0 votesanswersviews
如何“忽略”来自Apache Camel File Consumer的已获取交换
我有一个批处理文件使用者,它正在轮询许多不同进程将文件放到的公共目录 . 这些文件通过文件名上的guid“批处理”在一起 . 完成特定批处理后,应用程序将删除.done文件以触发camel文件使用者 . 我的问题是,我正试图找到一种可能“忽略”消息/交换的方法,这些消息/交换可能包含我不想处理的文件(即......不是我当前批次的一部分) . 另外,我希望“忽略”的交换不被camel处理(即..没... -
1178 votesanswersviews
Apache Camel究竟是什么?
我不明白Camel到底是做什么的 . 如果你能用101个单词介绍骆驼: 究竟是什么? 它如何与用Java编写的应用程序交互? 它与服务器一起出现了什么? 这是一个独立的计划吗? Please explain what Camel is. -
0 votesanswersviews
Camel:文件消费者组件“咬掉的东西超过它可以咀嚼”,管道因内存不足而死亡
我在Camel中定义了一个类似于这样的路由:GET请求进来,文件在文件系统中创建 . 文件使用者选择它,从外部Web服务获取数据,并通过POST将结果消息发送到其他Web服务 . 简化代码如下: // Update request goes on queue: from("restlet:http://localhost:9191/update?restletMethod=pos... -
0 votesanswersviews
Spring集成:使用有序订阅者发布/订阅 Channels 的异常处理
给定使用任务执行程序配置的发布 - 订阅通道,如果抛出异常,是否可以中断其有序订阅者的调用? 例如,在此示例中,“工作”消息仍然由序列中的第二个服务激活器发送 . 我希望这不会发生 . <int:publish-subscribe-channel id="input" task-executor="taskExecutor" /> &l... -
13 votesanswersviews
Spring集成 - 入站和出站通道适配器
What is the fundamental difference between inbound and outbound channel adapters? 任何例子都会非常有用 . 我已经回顾了Spring文档,这个"directional"的区别对我来说并不清楚 . 我支持配置了出站通道适配器的应用程序,但我发现行为计数器直观的出站标签 . 此适配器获取外部文件,然后... -
2 votesanswersviews
骆驼请求/回复关联
我有一个CXFRS endpoints ,其中诸如“GET / files / x”之类的请求应该从特定目录返回文件“x”然后将其删除 . 文件从另一个进程输出,然后通过此路由快速消耗 . 因此,如果需要,可以对它们进行轮询并暂时保存在内存中 . 以下是我的网络服务 . @Component @Path("/") public class WebService { @GET ... -
2 votesanswersviews
Apache Camel:保持路由信息完全独立于Java代码
首先感谢目前参与Camel开发的人们,我很感激他们所付出的辛勤劳动 . 我正在寻找一些设计建议 . 架构是这样的:我有一堆Java类,在实例化时需要相互连接并使用Apache Camel发送消息 . 设计约束要求我创建一个框架,使所有路由信息, 生产环境 者,消费者, endpoints 等都应该成为camel-context.xml的一部分 . 一个人应该有能力修改这样的文件并完全改变现有的路由... -
5 votesanswersviews
在Camel @Produce中产生了什么,而@Consume消耗了什么?
作为一个无关紧要的不太自以为是的观点,我发现阿帕奇骆驼文档太过冒昧,因为假设读者已经有了骆驼的背景 . 通常情况下,Web服务提供者是 生产环境 者,它生成的服务的客户是消费者 . 我们来看看http://camel.apache.org/pojo-producing.html . 其中说,有两种不同的方式向Camel Endpoint发送消息 . @EndpointInjecct (uri ..... -
0 votesanswersviews
Apache Camel消息格式
我刚刚开始使用Apache Camel 2.15.3的应用程序 . 我是Camel的新手,我正在尝试了解消息的发送方式以及路由中组件之间的内容 . 应用程序中的路由使用spring extension xml设置 . 以下是其中一条路线的样子 . <route id="register"> <from uri="{{in.queue}...