apache-camel相关内容

如何使用骆驼卡夫卡提交偏移线程安全?

根据问题如何手动控制使用camel-kafka 提交偏移量? 我想使用camel-kafka 手动提交偏移量.我的路线: .from(kafka:topic1).aggregate(新 GroupByExchangeStrategy()).to(kafka:topic2).process(新ManualCommitProcessor()) ，其中 ManualCommitProcessor 将 ..

发布时间：2022-01-19 08:44:33 apache-kafka apache-camel 其他开发

在骆驼中测试我的对象的正确方法

我正在尝试为 Camel 路线设置测试.我的测试路由读取一个二进制文件并将其发送到一个翻译器 bean，返回一个 POJO.现在，我想对 POJO 做一些断言，以确保那里的值与已知值匹配.我认为标准的东西.在我看到的示例中，body 似乎总是一个 String 或原始类型，并且可以对其进行简单的断言.但是，就我而言，它是一个对象，所以我想以某种方式获取该对象. 这是我迄今为止尝试过的: @ ..

发布时间：2022-01-19 08:44:22 java junit apache-camel Java开发

Camel Json 验证抛出 NoJsonBodyValidationException

我正在尝试对传入的 GET 请求执行标头验证.我提到了 Camel JSON 模式验证器组件 并按照以下步骤在我的项目中实现，即 在 build.gradle 中添加 camel-json-validator-starter 依赖 在我的 Spring boot 项目的 Resource 文件夹中添加 Employee.json(YAML 转换为 JSON).最初我在这里有 Open AP ..

发布时间：2022-01-19 08:44:12 rest validation apache-camel openapi spring-camel 其他开发

即使无法访问 MQTT 服务器如何启动骆驼

我想让我的 Apache Camel 应用程序更有弹性，即使在无法访问 MQTT 代理时也能启动.我们在互联网连接可能不稳定的 IoT 设备上使用 Camel，我希望即使没有互联网连接也能启动我们的应用程序. 示例路线如下所示: from("timer:heartbeat?period=5000").routeId("发送心跳").setBody(simple("Hello World!" ..

发布时间：2022-01-19 08:44:04 java apache-camel paho Java开发

如何在 Camel(最好是蓝图)的 CXF 端点 (SOAP) 中实现 OAuth 流?

我想通过 camel-cxf 端点 处理 SOAP Web 服务.如何实现 OAuth 流程，最好在蓝图中实现?这是可配置的还是我必须自己实现? 解决方案 我发现不错 文档 关于这个: 基本上，您必须实现拦截器和过滤器:您的 blueprint.xml ..

发布时间：2022-01-19 08:43:04 oauth-2.0 apache-camel cxf jbossfuse blueprint-osgi 其他开发

我如何专门发送到已开始的骆驼路线?

公共类 MyRoute 扩展 RouteBuilder {@覆盖公共无效配置(){从(“servlet://myservlet").multicast().parallelProcessing().recipientList(bean(this)).结尾();}@RecipientList公共列表路线(字符串体){返回 getContext().getRouteDefinitions() ..

发布时间：2022-01-19 08:42:37 java apache-camel Java开发

骆驼中有一个while循环吗?

在 Camel 中有一个 while 循环的想法吗?我们正在使用 Camel 进行批处理(不是我所知道的 ESB 的职权范围).当我在 ESB 中处理消息时，我想继续检查其他东西的状态.我只能找到一个循环定义次数的循环，即用于测试或每 x 秒检查一次的石英计时器.这两个都不合适. 有什么建议吗，还是我要求的只是 ESB 职权范围之外的东西? 解决方案 做这样的事情怎么样: ..

发布时间：2022-01-19 08:42:22 while-loop apache-camel esb do-while 其他开发

过滤掉自动回复邮件的骆驼路线

我正在使用 camel rout 来处理收件箱文件夹中的电子邮件.但我想过滤掉自动回复的电子邮件，例如不在办公室等. 我看到有一个选项可以使用选项 unseen=true 仅处理未读消息. 我用来消费电子邮件的 URI 如下所示: pop3://username@host?password=password;delete=true&unseen=true&consum ..

发布时间：2022-01-19 08:41:18 apache-camel 其他开发

在骆驼中设置 REST 响应主体

这是我尝试在 Camel 中设置的流程: GET/product/foo --> MULTICAST [HTTP URI 1, HTTP URI 2, HTTP URI 3] --> AGGREGATE --> 将聚合值返回到 HTTP 响应正文 我已经以这种方式设置了路由，但是在对原始 GET 的响应中没有得到任何数据. 如何获取聚合器返回的值? @Override公共无效 ..

发布时间：2022-01-19 08:41:08 java apache-camel Java开发

文件组件(Apache camel)delete=true 参数在 Windows 中不起作用

Apache Camel File 组件在 Windows7 中无法正常运行，而在 Linux 中运行没有任何问题. 我的要求: 文件处理后，必须从目录中删除文件.在 Windows 中，由于 .camelLock 文件无法正确删除. 多次尝试后，只有 Apache camel 可以从目录中删除文件.如果尝试无法从目录中删除文件，则会引发异常. 如果我在目录中只有一个文件， ..

发布时间：2022-01-19 08:40:47 apache-camel soa enterprise-integration 其他开发

随时接受更多 Observables 的 RxJava -2 Observables?

我目前正在使用 rx-java 2，并且有一个用例，即单个 Camel Route 订阅者需要使用多个 Observable.使用此解决方案作为参考，我有一个部分可行的解决方案.RxJava - 随时接受更多 Observable 的合并 Observable? 我打算使用 PublishProcessor 订阅一个骆驼反应流订阅者，然后维护一个 ConcurrentHashSet>我可以在 ..

发布时间：2022-01-19 08:40:41 java apache-camel rx-java rx-java2 Java开发

Apache骆驼SSL连接到restful服务

我正忙于一个项目，我必须使用特定证书对公开的休息服务进行 GET.我正在使用带有 https4 组件的 apache camel 框架.我创建了一个密钥库并使用soapUI对其进行了测试，它连接成功，但是我无法通过我的项目进行连接. 我使用以下页面作为参考:http://camel.apache.org/http4.html 我通过以下配置为 HTTP Client 设置 SSL: ..

发布时间：2022-01-19 08:40:33 apache rest ssl apache-camel 服务器开发

骆驼中的动态路由使消息无限排队

我正在开发骆驼的动态路由器，通过引用 http://camel.apache.org/dynamic-router.html 以下是骆驼配置xml: ..

发布时间：2022-01-19 08:40:13 spring apache-camel activemq 其他开发

如何使用基本身份验证配置 Camel CXF

我是 Apache Camel 和 CXF 的新手， 我正在尝试创建一个路由来查询需要基本身份验证的远程 WS 并指定 Soap Action 标头. 我能够使用骆驼 HTTP 组件实现相同的功能，但我需要使用骆驼 CXF在java DSL中 任何人都可以指导我们修复相同的问题 解决方案 如果你想使用camel-cxf组件设置Basic认证，你需要像这样在CxfEndpo ..

发布时间：2022-01-19 08:40:05 java cxf apache-camel Java开发

读取包含键值对的文件的内容，无需正常解析

我的方案是从文件端点读取文件，该文件仅包含键值 paris，如属性文件，并根据键从中获取一些数据. 知道如何使用自定义 bean 或 java 组件来完成它们. 我想知道这在 Mule 或 Camel 中是否可行. 提前致谢. 解决方案 如果你想使用 Camel 路由来获取文件，那么像这样 from("file:inbox").convertBodyTo(Propert ..

发布时间：2022-01-19 08:39:57 java apache-camel mule fuseesb jbossfuse Java开发

如果exxchange是一个列表，我想有条件地拆分一个列表并继续处理

如果它是一个列表，我正在尝试有条件地将交换拆分为其内容，否则将其保留为单个项目，并且两者都转到同一个处理器 理想情况下，我不想设置很多中间直接:端点来实现这一点 来自(X).when(body().isInstanceOf(List.class). 分裂(身体()).setHeader( "x", constant( "I don't care" )//需要设置为 split 必须至少有一 ..

发布时间：2022-01-19 08:39:40 apache-camel 其他开发

使用 Apache Camel 文件组件实现自定义流程策略

问题背景 我目前正在开发一个基于 Camel 的 ETL 应用程序，该应用程序处理出现在日期目录中的文件组.这些文件需要作为一个由文件名开头确定的组一起处理.只有将完成的文件(“.flag")写入目录后，才能处理这些文件.我知道骆驼文件组件有一个完成文件选项，但这只允许您检索与完成文件同名的文件.应用程序需要持续运行并在日期滚动时开始轮询第二天的目录. 示例目录结构: /进程目录/0 ..

发布时间：2022-01-19 08:39:30 apache-camel 其他开发

CamelJettyWebSocketServer，致命错误:42:空证书链

我尝试在自定义骆驼端点中建立相互验证的连接.我尝试进行测试.当我将 ClientAuthentication.REQUIRE 设置为 NONE 时，会建立 TLS 连接，一切正常.不过，我想对连接进行相互身份验证.当我将标志设置为 REQUIRE 时，我得到(启用完整调试输出): CamelJettyWebSocketServer-40，致命错误:42:空证书链javax.net.ssl.S ..

发布时间：2022-01-19 08:39:16 java ssl apache-camel Java开发

通过camel sql-stored组件调用存储过程

我是骆驼 sql 存储组件的新手.目前我正在使用 Camel 2.17.5.我正在尝试从骆驼路线调用 oracle 存储过程.这是我的路线: 约翰 ..

发布时间：2022-01-19 08:39:01 apache-camel camel-sql 其他开发

如何对 apache 骆驼路线的部分时间进行计时?

我有一个骆驼应用程序，它在路由构建器中定义了许多路由.其中一条路线有一个 xslt 管道，我想在 splunk 中记录其性能.日志格式需为: PerformanceDetailResultMs= 我已尝试执行以下操作但不起作用，因为 System.currentTimeMillis() 的结果由 spring 保留，因此当 routeBuilde ..

发布时间：2022-01-19 08:38:53 logging apache-camel 其他开发