apache-camel相关内容

骆驼子字符串操作 - 消息正文末尾的 n 个字符

这对你们大多数人来说可能是一个上篮，所以我提前道歉.我正在使用带有 spring DSL 的 Apache camel.我的消息正文已转换为字符串.我想要从第 9 个到第 998 个字符的所有内容，最好使用简单的表达式.我试过了 ${body.substring(8,${body.length}-1)} 但 Camel 无法识别减法.因此，它会尝试将 ..
发布时间：2022-01-19 09:02:45 其他开发

使用 Apache Camel 反复轮询只读文件系统中的文件(幂等 = false)?

我正在使用轮询消费者模式从给定的只读目录中读取所有文件并进行处理.是否有忽略幂等性的选项? 我了解使用 noop=true & 定义的路线idempotent=false 会使整个系统崩溃(无限循环)，但池化消费者模式是一次性操作，在给定时刻触发. 解决方案 camel file2 端点不会导致系统崩溃，因为它默认每秒轮询 2 次.它将从当时该文件夹中的所有文件创建一条消息.(好吧， ..
发布时间：2022-01-19 09:02:07 Java开发

骆驼分离器并行处理

我们有一个服务调用，它返回一个 id 列表，我们用它调用另一个服务，它一次只接受一个 id，所以我们使用骆驼拆分器，并行处理变为 true.现在我们对服务的调用是通过 seda 进行的，因此我们可以对其设置超时.这将导致并行处理不再是并行的问题，因为 seda 默认只有 1 个并发消费者在处理它. 选项: 在 seda 上放置一个 ?concurrentConsumers=x 使用直 ..
发布时间：2022-01-19 09:01:41 其他开发

使用 apache camel 转换器 EIP 将模块导入 xquery

我有一个非常简单的骆驼路线，除了使用的 xquery，这就是我将其提取到单独文件中的原因.在我的骆驼路线中，我使用 Transformer EIP 调用 xquery: .transform().xquery("resource:classpath:xquery/myCoolXQuery.xquery",String.class) XQuery 本身工作正常，但由于一些功能更改，我现在想导入另 ..
发布时间：2022-01-19 09:01:00 Java开发

ERROR 401 Unauthorized: Anonymous caller does not have storage.buckets.get access to the Google Cloud Storage bucket in spring boot application

我有一个使用骆驼从对象存储(谷歌云平台)获取数据的 Spring Boot 应用程序. 这是我在 Eclipse 中的代码: package footballRestAPIs；导入 org.apache.camel.builder.RouteBuilder；导入 org.springframework.stereotype.Component；导入核心.错误处理器；@零件公共类 ListO ..
发布时间：2022-01-19 09:00:46 Java开发

Camel Transacted:MQ 会话在每次提交时关闭

我有: 骆驼路线 (transacted=true)，从 MQ 队列消费 使用 Spring 的 WebSphereUowTransactionManager 事务性有效 在 IBM Liberty 上运行 但是，我收到了这条消息: 为目标“MY.QUEUE"设置 JMS 消息侦听器调用程序失败 - 尝试恢复.原因:本地JMS事务提交失败；嵌套异常是 com.ibm.msg.c ..
发布时间：2022-01-19 09:00:30 其他开发

骆驼自定义PropertiesComponent

我正在尝试通过 Spring 为我的 CamelContexts 配置自定义 PropertiesComponent.根据 this 页面，我只需要添加一个 org.apache 类型的 bean 定义.camel.component.properties.PropertiesComponent.但是，我的 CamelContext 没有选择它，而且我似乎找不到从 CamelContext 中引用 ..
发布时间：2022-01-19 09:00:22 其他开发

Apache Camel——Websphere MQ 集成

我有一个使用 apache-camel 解决方案的应用程序，想通过 jms 向 Websphere MQ 服务器发送消息，将 jms 属性 JMS_IBM_MQMD_MsgId 转换为 MQMD 字段 MQMD.MsgId，以便我通过骆驼在消息上设置此值 exchange.getIn().setHeader(WMQConstants.JMS_IBM_MQMD_MSGID, "XXXXXXXXXX ..
发布时间：2022-01-19 09:00:15 其他开发

骆驼不承认 ?lock=false 是有效的

我从文件中读取了骆驼路线，并且在路线完成后它没有删除 .CamelLock 文件，所以我想关闭锁定.Camel-File 的文档说该属性是“锁定"，但是当我执行 我得到: 原因:org.apache.camel.ResolveEndpointFailedException: 失败解决端点:file:///da ..
发布时间：2022-01-19 08:59:48 Java开发

将 Spring bean 传递给 Camel 组件

我有一个 FooComponent 类型的自定义组件，它通过以下几行添加到路由中: from("foo://bar?args=values&etc").bean(DownstreamComponent.class)... FooComponent 创建一个端点和消费者(类型为 FooConsumer)，然后发出消息到达 DownstreamComponent 和其余的管道. 为了监控，我 ..
发布时间：2022-01-19 08:59:40 其他开发

Camel rest dsl json包含转义序列

我需要骆驼方面的帮助.我准备了一些休息服务，但我的反应有点小问题.我的回复在“之前包含转义序列.有人可以帮我解决这个问题吗? 我的配置: restConfiguration().port("{{rest_port}}").component("jetty").host("localhost").bindingMode(RestBindingMode.json);rest("/login") ..
发布时间：2022-01-19 08:59:26 其他开发

基于 Apache Camel 内容的 Websocket 连接路由

我有一个假设场景:假设我有一个 Apache Camel websocket 服务器，并且我允许许多 websocket 连接.每个客户端连接都需要与一个 ClientID 相关联.ClientID 是通过新连接通过 InitConnection json 消息获得的，其中 ClientID 是消息的成员.问题是:是否可以让骆驼将 websocket 实例与 ClientID 关联起来以执行基于内 ..
发布时间：2022-01-19 08:58:49 其他开发

Apache Camel 代理不工作

问题也可能与我对这个概念的理解有关. ActionClass 正在调用代理 bean，即 AccountingInterface.代理 bean 接口是用 AccountingUtil 类实现的.所以我期望 AccountingUtil 返回的 xml 将通过 seda:accountingQueue 传递，然后在控制台上流出. ApplicationContext ..
发布时间：2022-01-19 08:58:35 Java开发

使用骆驼 JMS 流式传输

我有一个将消息放入 JMS 队列的应用程序.消息大小可以达到 150 mb.JMS 消息包含带有附加元数据的字节数组数据作为 xml，一旦将消息放入队列中，骆驼路由应用程序就会选择消息并使用消息调用外部 java api.我想使用骆驼 jms 从 JMS 队列中流式传输消息零件.你能告诉我是否可以使用骆驼来实现它.目前我正面临堆错误问题. JMS 消息示例如下. ..
发布时间：2022-01-19 08:57:59 其他开发

定义多个 kafkaComponent bean 时，Kafka Camel Spring Boot AutoConfiguration 不会被拾取

我目前正在使用 这个 camel-kafka-startermaven 依赖 在 Spring Boot 中自动配置我的 kafka camel 组件. 如果我添加说，像这样的设置 camel.component.kafka.configuration.linger-ms=20.Camel kafka 组件在路由中拾取它，我可以在日志输出中看到它的配置值.例如 @Component公共类路 ..
发布时间：2022-01-19 08:57:52 Java开发