Apache Camel是一个功能强大的开源集成框架,基于已知的企业集成模式和强大的Bean集成
我正在尝试从camel 3更新到4,但我对以下行有问题, CamelContext.adapt(ExtendedCamelContext.class).setUnitOfWorkFactory(new CustomUnitOfWorkFactory()); 我找到了...
如何使用带有 ClientID 和令牌的camel-azure-servicebus
我在 ActiveMQ 中运行 Camel 尝试连接到 Azure ServiceBus 队列,但 org.apache.camel.component.azure.servicebus.ServiceBusConfiguration 似乎只接受连接字符串
升级到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
使用 Apache Camel 升级 2.25+ 时交换属性映射到速度模板时出错
我在 Spring boot 应用程序上将 Apache Camel 速度升级到 2.25.4 现在我无法从速度模板访问交换属性。仅检索模板而没有值。
为什么 dataChangeFilterDeadbandValue 键无法使用 Apache Camel OPC UA 客户端工作?
我正在使用 Apache Camel OPC UA 客户端组件来测试具有死区值的数据更改过滤器,以从工业网关 OPCUA 服务器获取单个标签值。 c当前软件版本...
Apache Camel Kafka 组件连接到 Azure 事件中心时出现身份验证错误
我正在尝试使用 Apache Camel 4.4.3 及其 Java 17 上的 Kafka 组件(在 Windows 10 下运行)将消息发送到 Azure 事件中心(高级)。虽然我已成功使用其他 Kafka
在 Apache Camel Quarkus 中使用进程时 @ConfigProperty 为 null 的问题
早上好,我目前正在使用 Quarkus 和 Apache Camel,我正在处理器中使用 application.properties 中的变量,我尝试使用 @ConfigProperty 注释将其引入...
apache 骆驼测试 我有我的路线 FirstRoute,它最后多播并发送到 SecondRoute。 我正在编写我的路由测试,我注意到如果 Second_route 需要更长的时间,多播就会启动新线程
Spring Boot 中的 Camel 不读取 application.yml 设置
我在 application.yml 中设置了以下内容: 骆驼: 成分: http: 跟随重定向: true ..但仍然没有遵循重定向: 处理交换时发生错误:...
在 Apache Camel Quarkus 中配置缓存过期时间
我正在quarkus中使用apache Camel,并且我在一定时间后启用缓存删除,但我无法删除它,即我使用属性camel.component.caffeine-cache.expire-after-access...
骆驼路线用于处理多行csv文件。路由 from 使用查询参数 moveFailed 配置。这一切基本上都有效。但行是被一一处理的,如果......
如何使用 apache Camel 从 google Sheets api 检索所有工作表数据
我希望能够从Google表格中检索所有工作表(sheet1,sheet2,...等)数据,而不仅仅是一张工作表(在本例中为sheet1): from("计时器:运行?repeatCount=1") .to(&q...
使用 Blueprint XML 和 Java Bean 的 Apache Camel 3.14.7 路由单元测试出现问题
我正在开发一个使用 Apache Camel 3.14.7 的项目,结合 Blueprint XML 和 Java beans 进行路由定义。我面临着对这些路线进行单元测试的问题,它们涉及复杂的操作......
替换 Camel 3.16 中删除的 newExchange()
我终于开始升级旧的 Camel 2.x 堆栈了。 WireTapDefinition.newExchange(Processor 处理器) 在 3.16 中被删除,我还没有找到任何如何替换它的示例。 什么
在bean中找不到:org.apache.camel.converter.stream.InputStreamCache
有一个下面的脚本,它抛出一个错误: .log("消息:${body}") //消息:{“caListID”:88186,“ciqWatchListID”:706596203} .setHeader(KafkaConstants.K...
Apache Camel 动态文件移动在 from() 和 toD() 端点中均不起作用
我正在使用apache Camel开发Spring Boot微服务,通过sftp与外部系统集成。我正在尝试在入站和出站方法中将文件移动到不同的文件夹。 S...
如何使用 CSVWriter 仅在 csv 中嵌入的逗号字符串上使用双引号?
这是我在输出 csv 中预期的结果格式: 标头1,标头2,标头3,标头4 莫妮卡、钱德勒、“瑞秋、罗斯”、乔伊 我目前的结果: 策略1: CSVWriter csvWriter = 新的 CSVWriter...
Apache Camel 拆分、标记化和流式传输 - 最后一个元素
我有以下骆驼路线 来自(“文件://目标/输入/?删除= true”) .log("开始处理 [${header.CamelFileNameOnly}] ...") .split(body().tokenize(" &qu...
我们基于Apache Camel 3.x实现了一个简单的路由引擎应用程序,支持动态路由配置加载:其他应用程序可以通过添加...来扩展路由引擎