apache-camel 相关问题

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

Apache Camel,将文件上传到 S3 存储桶中的文件夹

我尝试将文件上传到 s3 存储桶下的文件夹,但收到如下错误: 请帮忙。 提前致谢, 普拉迪普 引起:software.amazon.awssdk.services.s3.model。

回答 1 投票 0

如何在带有Zookeeper和ActiveMQ的集群环境中使用Apache Camel

我有 3 个服务器(1 个主服务器,2 个从服务器)。每个都安装了Zookeeper(最新版本)和ActiveMQ“Classic”。 ActiveMQ“经典”配置为基于复制级别数据库...

回答 1 投票 0

执行器 JMS 运行状况检查使用 Java 配置返回误报

我遇到了一个问题,即执行器探测 JMS 运行状况失败,即使我的路由可以连接并向 JMS 生成消息。简而言之,执行器说它已关闭,但它正在工作。 技术

回答 1 投票 0

Camel Spring 使用 ActiveMQ Artemis Proton/Qpid 客户端进行远程处理 - 挂起发送消息

当我使用Camel Spring远程处理配置发送一些消息时,生产者和消费者都在不同的JVM中运行。 使用 Apache ActiveMQ Artemis 2.14.0 版本 骆驼版本...

回答 1 投票 0

将 CSV 文件转换为 JSON 并将其发送到 JMS 队列

我的目标是读取CSV文件,将其转换为JSON,并将生成的JSON一一发送到JMS队列。我的代码如下: 最终 BindyCsvDataFormat bindy=new BindyCsvDataFormat(camelproject.EquityFeeds.

回答 1 投票 0

检查天气处理器是否在 Camel 路由器中设置任何交换消息

我只是想创建一条具有多个处理器的路线。是否可以检查任何特定处理器是否正在设置任何交换。我正在尝试检查 xml 正文中的消息字段是否

回答 1 投票 0

Apache Camel 端点处理启动时的失败

我想建立一个高可靠的服务,所以我需要在NATS端点处理各种网络问题; 启动异常,处理启动时的异常,我注意到如果

回答 1 投票 0

禁用 Quarkus Camel 启动信息/横幅

我正在使用 Quarkus 3.2.6 和 Apache Camel 4.0.0。当它启动时,会记录各种启动信息。我如何禁用此功能?我已经设置了 quarkus.banner.enabled=false 但信息

回答 1 投票 0

SSLException:无法识别的 SSL 消息,明文连接?通过 PROXY 在 Camel 中发送 https POST 时出错

我正在尝试通过代理使用camel https4组件连接到外部https端点。 为此,我在 Linux (18.04) 中设置了鱿鱼代理。 根据参考文献[http://camel.apache.org/h...

回答 1 投票 0

如何正确启动延迟路线并获取状态?(Camel v3!!!)

builder.from(fileOptions.toString()) .id("rabbitMQ") .noAutoStartup() 马克出发路线: 路线route =camelContext.getRoute("rabbitMQ");...

回答 2 投票 0

SoapFault 详细信息未填充在 Apache Camel Cxf 中

我有一个如下的路由,即使我尝试用 onException() 子句替换 try-catch 并将在下面的路由中设置为 true : 来自(“直接:创建肥皂请求”) .process(除...

回答 1 投票 0

Debezium SqlServerConnector(数据库中没有记录最大LSN)

我有一个使用 Debezium Embedded 实现并使用 Apache Camel 构建的 CDC(变更数据捕获)应用程序。在分析 pod 日志时,一切似乎都运行正常,除非...

回答 1 投票 0

如何使用 Spring boot 在 Camel Consumer 中为 IBM MQ Connection Factory 设置 MQOO_INPUT_EXCLUSIVE 选项?

我正在尝试设置需要使用来自 IBM MQ 队列的消息的 Spring Boot 应用程序,同时确保应用程序的只有一个实例接收所有消息来维护消息

回答 1 投票 0

如何将 Apache Camel 与 MSK 架构注册表连接

我已经在AWS GLUE的MSK中创建了一个架构,但我无法使用应用程序的生产者来配置它。 在 MKS 中创建的架构: 架构已创建 卡夫卡配置: 类 KafkaConfig { @瓦尔...

回答 1 投票 0

OpenShift Developer Sandbox:DC 未部署

我正在尝试在 OpenShift Developer Sandbox 上部署几个 Quarkus Camel 微服务。当在 Minikube 上本地部署时,它们按预期工作,但是在 Openshift 上,我不断收到以下信息

回答 1 投票 0

如何在camel中的onRedelivery之前执行onException块中的操作?

我在骆驼路线中有一个 onException 块。它看起来像这样: ... .onException(SomeException.class) .最大重新交付次数(3) .redeliveryDelay(5000) .onRedelivery(e -> {log()}) .

回答 1 投票 0

Spring Boot Apache Camel 应用程序中不存在函数 IN/1

以下澄清: 使用 jq 表达式,如何使用中间映射数组从 json 数组返回项目? 我尝试实施该解决方案: [.链接[] |选择(.fr...

回答 1 投票 0

骆驼分裂机加工顺序

如果我在camel中拆分List时不指定parallelProcessing(),Camel会按顺序处理项目吗?

回答 2 投票 0

当deleteAfterRead为假时,幂等Camel AWS2-S3消费者无法从存储桶中检索所有文件

我将 Camel AWS2-S3 与基于 MemoryIdempotRepository 的幂等消费者一起使用,并尝试使用 Camel AWS2-S3 版本 3.14.2 读取 AWS/S3 存储桶中的所有文件。目的是保持...

回答 2 投票 0

Apache Camel - 如何在 split(body()).streaming().aggregate 之后使用丰富()?

Camel 3.21 & String Boot 2.7.15 公共无效配置()抛出异常{ AggregationStrategy arrayListStrategy = AggregationStrategies.flexible(Document.class) .

回答 1 投票 0

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