apache-camel 相关问题

Apache Camel是一个功能强大的开源集成框架,基于已知的企业集成模式和强大的Bean集成

Camel 3 -> 4 工作单位

我正在尝试从camel 3更新到4,但我对以下行有问题, CamelContext.adapt(ExtendedCamelContext.class).setUnitOfWorkFactory(new CustomUnitOfWorkFactory()); 我找到了...

回答 1 投票 0

如何使用带有 ClientID 和令牌的camel-azure-servicebus

我在 ActiveMQ 中运行 Camel 尝试连接到 Azure ServiceBus 队列,但 org.apache.camel.component.azure.servicebus.ServiceBusConfiguration 似乎只接受连接字符串

回答 1 投票 0

升级到camel-azure-servicebus-4.4.2后,CamelAzureServiceBus标头丢失

我有一个到 xml 中定义的 Azure 服务总线队列的连接 我有一个到 xml 中定义的 Azure 服务总线队列的连接 <route id="Elexon_IRIS_Route"> <from uri="azureQueueEndpoint" /> <convertBodyTo type="java.lang.String"/> <unmarshal><json/></unmarshal> <to uri="localAMQ:topic:IRIS-Elexon"/> </route> <bean id="azureServiceBusComponent" class="org.apache.camel.component.azure.servicebus.ServiceBusComponent"> <property name="configuration"> <bean class="org.apache.camel.component.azure.servicebus.ServiceBusConfiguration"> <property name="credentialType" value="TOKEN_CREDENTIAL" /> <property name="tokenCredential" ref="azauth" /> <property name="fullyQualifiedNamespace" value="elexon-iris.servicebus.windows.net" /> </bean> </property> </bean> 使用 camel-azure-servicebus-4.4.1 我得到每条消息返回的以下标头: {"expires"=>"0", "CamelAzureServiceBusEnqueuedSequenceNumber"=>"10655170", "destination"=>"/topic/IRIS-Elexon", "CamelAzureServiceBusDeliveryCount"=>"0", "ack"=>"ID:bravo-43103-1716763678894-2:59", "CamelAzureServiceBusSubject"=>"MELS", "subscription"=>"4b0062c6-48be-4cb2-abce85d1481b3401", "priority"=>"4", "CamelAzureServiceBusSequenceNumber"=>"7955951", "CamelAzureServiceBusMessageId"=>"MELS_202405262248_85602.json", "message-id"=>"ID:bravo-43103-1716763678894-10:1:3:1:1272", "persistent"=>"true", "timestamp"=>"1716763744004", "CamelAzureServiceBusLockToken"=>"64179600-27db-48ed-be93-eb19ebe0f66b"} 但是当我更改为 camel-azure-servicebus-4.4.2 时,我得到的唯一标题是: {"expires"=>"0", "destination"=>"/topic/IRIS-Elexon", "ack"=>"ID:bravo-34173-1716750388709-2:15634", "subscription"=>"16b02d1f-40df-4f31-b538738618f91316", "priority"=>"4", "message-id"=>"ID:bravo-34173-1716750388709-10:1:5:1:43221", "persistent"=>"true", "source_file_name"=>"MELS_202405262245_85595.json", "timestamp"=>"1716763562372"} 如何取回 CamelAzureServiceBus 标头?我对处理脚本中的内容进行过滤,因此这是一个相当重大的更改。 我在文档中看不到任何明显的更新,但是有thisJIRA 这是由 4.4.2 中的错误引起的,现已解决并确认按 4.4.3 中的预期工作 https://issues.apache.org/jira/browse/CAMEL-20699 https://issues.apache.org/jira/browse/CAMEL-20691

回答 1 投票 0

使用 Apache Camel 升级 2.25+ 时交换属性映射到速度模板时出错

我在 Spring boot 应用程序上将 Apache Camel 速度升级到 2.25.4 现在我无法从速度模板访问交换属性。仅检索模板而没有值。

回答 1 投票 0

为什么 dataChangeFilterDeadbandValue 键无法使用 Apache Camel OPC UA 客户端工作?

我正在使用 Apache Camel OPC UA 客户端组件来测试具有死区值的数据更改过滤器,以从工业网关 OPCUA 服务器获取单个标签值。 c当前软件版本...

回答 1 投票 0

Apache Camel Kafka 组件连接到 Azure 事件中心时出现身份验证错误

我正在尝试使用 Apache Camel 4.4.3 及其 Java 17 上的 Kafka 组件(在 Windows 10 下运行)将消息发送到 Azure 事件中心(高级)。虽然我已成功使用其他 Kafka

回答 1 投票 0

在 Apache Camel Quarkus 中使用进程时 @ConfigProperty 为 null 的问题

早上好,我目前正在使用 Quarkus 和 Apache Camel,我正在处理器中使用 application.properties 中的变量,我尝试使用 @ConfigProperty 注释将其引入...

回答 1 投票 0

apache 骆驼测试等待多播完成处理

apache 骆驼测试 我有我的路线 FirstRoute,它最后多播并发送到 SecondRoute。 我正在编写我的路由测试,我注意到如果 Second_route 需要更长的时间,多播就会启动新线程

回答 1 投票 0

Spring Boot 中的 Camel 不读取 application.yml 设置

我在 application.yml 中设置了以下内容: 骆驼: 成分: http: 跟随重定向: true ..但仍然没有遵循重定向: 处理交换时发生错误:...

回答 1 投票 0

在 Apache Camel Quarkus 中配置缓存过期时间

我正在quarkus中使用apache Camel,并且我在一定时间后启用缓存删除,但我无法删除它,即我使用属性camel.component.caffeine-cache.expire-after-access...

回答 1 投票 0

将文件移动到骆驼路线失败

骆驼路线用于处理多行csv文件。路由 from 使用查询参数 moveFailed 配置。这一切基本上都有效。但行是被一一处理的,如果......

回答 1 投票 0

如何使用 apache Camel 从 google Sheets api 检索所有工作表数据

我希望能够从Google表格中检索所有工作表(sheet1,sheet2,...等)数据,而不仅仅是一张工作表(在本例中为sheet1): from("计时器:运行?repeatCount=1") .to(&q...

回答 1 投票 0

使用 Blueprint XML 和 Java Bean 的 Apache Camel 3.14.7 路由单元测试出现问题

我正在开发一个使用 Apache Camel 3.14.7 的项目,结合 Blueprint XML 和 Java beans 进行路由定义。我面临着对这些路线进行单元测试的问题,它们涉及复杂的操作......

回答 1 投票 0

替换 Camel 3.16 中删除的 newExchange()

我终于开始升级旧的 Camel 2.x 堆栈了。 WireTapDefinition.newExchange(Processor 处理器) 在 3.16 中被删除,我还没有找到任何如何替换它的示例。 什么

回答 1 投票 0

在bean中找不到:org.apache.camel.converter.stream.InputStreamCache

有一个下面的脚本,它抛出一个错误: .log("消息:${body}") //消息:{“caListID”:88186,“ciqWatchListID”:706596203} .setHeader(KafkaConstants.K...

回答 1 投票 0

消息模型中的“附件”是什么意思?

我读了《骆驼在行动》这本书。但我无法理解“附件”在其消息模型中的含义。 我知道什么是标题,例如“发件人信息”、“

回答 1 投票 0

Apache Camel 动态文件移动在 from() 和 toD() 端点中均不起作用

我正在使用apache Camel开发Spring Boot微服务,通过sftp与外部系统集成。我正在尝试在入站和出站方法中将文件移动到不同的文件夹。 S...

回答 1 投票 0

如何使用 CSVWriter 仅在 csv 中嵌入的逗号字符串上使用双引号?

这是我在输出 csv 中预期的结果格式: 标头1,标头2,标头3,标头4 莫妮卡、钱德勒、“瑞秋、罗斯”、乔伊 我目前的结果: 策略1: CSVWriter csvWriter = 新的 CSVWriter...

回答 2 投票 0

Apache Camel 拆分、标记化和流式传输 - 最后一个元素

我有以下骆驼路线 来自(“文件://目标/输入/?删除= true”) .log("开始处理 [${header.CamelFileNameOnly}] ...") .split(body().tokenize(" &qu...

回答 1 投票 0

如何在Camel 4.x中使用rabbitmq组件迁移路由

我们基于Apache Camel 3.x实现了一个简单的路由引擎应用程序,支持动态路由配置加载:其他应用程序可以通过添加...来扩展路由引擎

回答 1 投票 0

© www.soinside.com 2019 - 2024. All rights reserved.