动态“从"怎么做?端点和交换在骆驼中工作?
我有点纠结于动态路由概念和消费者规则. 假设我有一个包含交换数据的路由，然后我想在“来自"端点的不同路由中使用来自交换的标头. 我认为它看起来像这样: 路线 1: from("file:/dir1")....to(“直接:开始")； 路线 2: from("direct: start")//获取旧的交换数据.from("file:/dir1/?fileName=${head
..
apache-camel相关内容
Camel-K 不识别本地包
我有一个使用自己的处理器的 RouteBuilder 类.使用 Maven 在 Camel 中本地运行时，它运行良好.但是，当我尝试使用 camel-k 时，它说找不到包.我有什么需要做的吗? 我的处理器 包 com.test.processor;导入java.io.File；导入 org.apache.camel.Exchange；导入 org.apache.camel.Message；
..
apache骆驼cxf https不工作
我正在尝试使用 apache camel cxf 发布 Web 服务.我可以使用 http 访问已发布的 web 服务.但是我正在尝试使用 https 进行相同的配置.但我无法让它工作. 以下是部分 spring 上下文和 wsdl 文件 .*_EXPORT_.*.*_EXPORT1024_.*
..
骆驼发送多部分/表单数据请求
我有一个应用程序，它发送一个 multipart/form-data &接收 multipart/form-data 请求的应用程序. 在接收器中处理: InputStreamCache postBody = exchange.getIn().getBody(InputStreamCache.class);MultipartUploadContext mux = new Multipar
..
Camel 2.11 批量聚合如何与单独的路由一起使用?
首先有一个类似的未回答问题将路由加入单个聚合器 我们有一些消费者路由(ftp、file、smb)从远程系统读取文件.简化了直接路由的测试，但与批处理消费者的行为相似: from("direct:"+routeId).id(routeId).setProperty(AGGREGATION_PROPERTY，常量(routeId)).log(String.format("发送 (${body}
..
Apache Camel - 拆分和聚合 - 旧 Exchange 始终为空
我看到这个问题已经被问过很多次了，但没有一个帖子有帮助，也没有一个决定性的解决方案.我正在拆分一条消息，然后使用 Aggregator2 对其进行聚合.代码抛出异常，因为 oldExchange 始终为空.所以为了测试我设计了一个小代码. 我读了一个订单，xml文件，看起来像这样 1
..
异步骆驼组件 - 立即调用 doStop()
我正在尝试创建一个使用来自外部服务的 API 的骆驼组件. 我的路线如下 from("myComponent:entity?from=&to=").to(“seda:one")来自(“seda:one").aggregate(常量(真)，新 GroupedBodyAggregationStrategy()).completionSize(5).completionTimeout(5000)
..
使用 Camel 的 REST 服务调用需要首先调用身份验证 api
Camel 必须调用 REST 服务进行某些集成，但是，REST 服务有一个身份验证 api (POST api)，需要首先调用它来获取令牌，然后必须调用嵌入令牌的其他后续 api 调用在 HTTP 请求的标头中. Spring Restemplate 或 apache camel 是否有一些 api 来支持相同的功能? 解决方案 遵循@gusto2 方法，它几乎工作正常. 所
..
Apache Camel - 多部分文件上传
使用 Apache-Camel ESB，尝试将 xlsx 文件上传到 Spring Rest Web 应用程序.从 apache-camel ESB 上传失败.但是从 Postman 上传可以正常工作.下面共享代码片段. 骆驼路由器中的处理器代码如下 from("file://data/PASInput").process(new Processor() {@覆盖公共无效进程(交换交换)
..
来自骆驼上下文的堆栈跟踪 onException
我正在尝试从 Apache Camel 中的 onException 处理程序中检索堆栈跟踪: java.lang.Exception真${异常} 但是，上面只显示了异常而不
..
如何:Apache Camel、正则表达式匹配文件
我正在尝试让骆驼做一些文件操作并将它们传递给 activeMQ 代理，我从一个最近退出的人那里接手了这个项目. 到目前为止我得到了什么:
..
使用 MockEndpoints 测试骆驼
我有一系列“流水线"组件，它们都通过 ActiveMQ 消息队列进行通信.每个组件都使用 Camel 将这些队列中的每一个视为一个端点.每个组件都使用相同的基本模式: 每个组件使用输入队列中的消息，处理消息，然后将 1+ 消息放在出站/输出队列中.然后“输出"队列成为链中下一个组件的“输入"队列.很基本. 我现在正试图卷起袖子，使用 Camel 的测试 API 提供的 MockEndp
..
如何使用骆驼杰克逊将 JSONArray 转换为对象列表
我的 json 数组字符串如下 {“公司":[{“身份证":1001，“名称":“约翰"},{“身份证":1002，“名称":“约翰"}]} 我想将此 jsonarray 转换为 List .为此，我添加了 maven 依赖项“camel-jackson"，并为员工编写了 pojo 类.但是当我尝试运行下面的代码时 ObjectMapper 映射器 = new Obje
..
无法使用 apache camel 读取条形码
您好，我尝试使用以下代码从图像中读取条码，但我无法读取该文件，因为它包含多个条码.有什么解决办法吗? @GetMapping(value = "OCR/Apachecamel")@ApiOperation(value = "从 Barcode Apachecamel 库中获取结果")公共 BarcodeInfo GetApachecamelResult() 抛出异常 {尝试 {InputStre
..
骆驼如何向注册表添加一些东西 - 通常使用 java
有时我必须向骆驼注册表添加一个对象(当然是使用 java).在大多数情况下，它是一个数据源. 我的问题是我想不出一个通用的工作方式. 我总是开始获取注册表: getContext().getRegistry(); 但是“注册表"没有任何添加对象的方法.所以我必须尝试(使用调试器)正在使用什么样的注册表 getContext().getRegistry(some.class)
..
Exchange.getIn().getBody() 在第二次调用时返回骆驼的空字符串
我有 2 个相同的电话: String msg1 = exchange.getIn().getBody(String.class);字符串 msg2 = exchange.getIn().getBody(String.class); 在 msg1 中，我得到了正确的期望值，但 msg2 是一个空字符串.我没有设置 Out 消息，因此交换 In 消息应该仍然完好无损.请解释为什么会这样.
..
apache camel - 打包一个可执行的jar
我正在使用 maven 构建我的 jar (Intellij IDEA IDE).它是使用 Apache Camel 构建的应用程序.摘自我的 pom.xml: org.apache.maven.pluginsmaven-jar-pluginMainDri
..
如何使用 Apache Camel 来监控文件更改?
我想监视给定目录中的所有文件的更改，即更新的时间戳.对于使用文件组件的 Camel 来说，这个用例似乎很自然，但我似乎找不到配置这种行为的方法. 类似的uri: file:/some/directory 将使用提供的目录中的文件，但会删除它们. 类似的uri: file:/some/directory?noop=true 在添加文件或启动路由时使用每个文件一次. 令人惊讶
..
在 Java 中运行时添加骆驼路线
如何在 Java 运行时添加骆驼路线?我找到了一个 Grails 示例，但我已经用 Java 实现了它. 我的 applicationContext.xml 已经有一些预定义的静态路由，我想在运行时向它添加一些动态路由.是否可以?因为包含动态路由的唯一方法是编写 route.xml，然后将路由定义加载到上下文中.它将如何在现有的静态路由上工作?运行时路由 解决方案 你可以简单地在 C
..
Apache Camel 到底是什么?
我不明白 Camel 到底是做什么的. 如果你能用 101 个字来介绍一下 Camel: 究竟是什么? 它如何与用 Java 编写的应用程序交互? 它是与服务器一起使用的吗? 它是一个独立的程序吗? 请解释一下什么是骆驼. 解决方案 如果你有 5 到 10 分钟，我一般建议大家阅读这篇 与 Apache Camel 的集成 作者:Jonathan Anstey.这是
..