问题标签 [spring-camel]

我正在开发一个骆驼应用程序，我想在其中将 bean 的范围保持在路由级别。这意味着，如果我从两个不同的路由调用一个 bean，则应该创建两个实例。但是在该路由中，应该为该 bean 使用相同的单个实例。以下是我的代码：

这里应该在路线 2 中创建单独的 bean 实例。如果有任何想法，请提出建议。

无论我将数据格式放在 XML DSL 蓝图中的哪个位置，我都会从不同的位置开始出现此错误。如果我删除它，它可以工作，但我当然不能将 JSON 转换为 POJO。？？？任何帮助或告诉我我做错了什么，我错过了什么。谢谢！

错误

XML DSL

如果我将数据格式放在属性之上，它会抱怨，我必须删除属性和流缓存语句才能使其工作。但我需要代理属性。有什么建议么？？？再次感谢

如果

我明白了

我错过了什么？

我是 Apache Camel 的新手，有一个 ApiRest 用于消费，它的响应是 gzip，我尝试了这个，但它不起作用。

例外是

原因：[java.util.zip.ZipException - 不是 GZIP 格式] java.util.zip.ZipException：不是 GZIP 格式

标题：

• 内容类型 -> 文本/xml；charset=utf-8
• 内容编码 -> gzip

我使用 Camel-http4 是因为我只需要一个生产者，而不是公开一个网络服务。我只需要将文件推送到 HTTP 服务器，所以这是一个客户端实现。我面临的问题是尝试发布返回错误。

CamelHttpResponseCode=403，CamelHttpResponseText=禁止

{"timestamp":"2018-05-03T20:36:20.571","traceId":"","path":"[POST] https://apm-query-svc-prod.apm-api.com/ v2/t_series/upload%2520?throwExceptionOnFailure=false ","errors":[{"httpStatusCode":"FORBIDDEN","code":"FORBIDDEN","message":"解析多部分 servlet 请求失败；嵌套异常是java.io.IOException: org.apache.tomcat.util.http.fileupload.FileUploadException: 请求被拒绝，因为没有找到多部分边界","detail":null,"requestId":null}]}

问题，有没有办法用 Camel-HTTP4 做到这一点？如何/可以做到这一点？谢谢！

这是路线

这是类，我只是设置了标头，然后 URI 被 Exchange.HTTP_URI 提供的覆盖。

公共类 UploadProcessor 实现处理器 {

这是我的第一次 HTTP 介绍，不熟悉多部分边界，我希望有一种简单的解决方案。：） 谢谢你 ！！！

解决方案一点也不难，这是基于拉尔夫回答的最终结果。谢谢大家！困难的部分是找到导入包并且它具有依赖关系。添加到 POM

我的 SpringBoot Camel 应用程序有问题。

它与非嵌入式代理非常有效。这是它的配置： URL 以字符串形式给出，指向独立的 ActiveMQ 服务器或嵌入式代理 URL (vm://dpcgbroker?broker.persistent=false)

当我切换到嵌入式代理时，行为不同，Apache ActiveMQ 开始然后停止，然后重新启动。我不知道为什么，也没有例外

这是日志的摘录

问题是在代理的第一个实例中发送的一些消息在它停止时会丢失，然后第二个实例以空的消息列表开始。我不知道它为什么停止。

PS：我不想使用持久嵌入式代理，这是无用的解决方法

我正在使用camel替换文件中的数据（它是400 MB的大文件），即使文件正在使用（它处于写入模式），我也面临其他消费者拾取文件的问题。

骆驼有没有办法锁定处于写入模式的文件，这样另一个消费者/路线就不能消费了。它应该在写入完成后消耗。我尝试使用 readLocks 但到目前为止没有运气。

我在 Spring Boot 1.5.8 应用程序中使用 Camel 2.19.2。例如，如果我想让我的几条路线“状态感知”，我该如何实现呢？我所说的“状态感知”是指路由将启动，通知组件工作流已经开始，然后它将执行特定于路由的逻辑，完成后，它将通知组件工作流已完成。如果可能的话，我希望这自动发生，并且不必在我想使用此功能的每个路由构建器中调用特定逻辑。

这是一个代码示例，就像我的意思：

从概念上讲，这几乎就像 AOP，所以我希望能够在一个地方定义此行为并将其包含在需要使用此行为的一些路由中。有没有办法可以做到这一点？我看到有用于测试的adviceWith，但我需要这个用于常规操作。提前致谢。

我使用骆驼重试在我的代码中实现了重试功能。它将重试最多五次。

现在我想在达到阈值而不是抛出异常时调用自定义方法。我怎样才能做到这一点？

我正在尝试在 apache karaf 中部署骆驼弹簧应用程序。我正在使用 Maven 来解决依赖关系。该应用程序在 Intellij 中运行良好，但是当我在 karaf 中部署应用程序（以及所有项目依赖项）时，应用程序将无法启动。

谁能告诉我在 karaf 部署骆驼弹簧应用程序的正确方法是什么？以及解决项目依赖关系的最佳方法？

骆驼版：2.16.5 卡拉夫：4.2.0

我有基于 SOAP 的服务，它接受一些预定义的请求对象，

例如，AccountRequest 有一些字段。

示例代码

上面的代码抛出错误

这是通过骆驼调用肥皂服务的正确方法吗？

依赖项