Apache Camel是一个功能强大的开源集成框架,基于已知的企业集成模式和强大的Bean集成
无法创建CamelSalesforcesourceSourceConnector:ResolveEndpointFailedException
背景:我是一名Python开发人员,从未使用过Java。 Camel Salesforce Source Connector:v3.20.6(我尝试过 3.21.0 和 4.0.0,但遇到了同样的问题) 卡夫卡:v3.6.1 问题: 尝试...
Apache Camel 将 XML DSL 中每个路由的日志记录到专用目录
如何在 XML DSL 中将每个 Apache Camel 路由定义为单独的专用目录/文件夹的日志记录?我们希望保留现有的记录器。 非常感谢您对前任的清晰而详尽的答复...
如何在quartz.properties文件中动态设置jobstore数据源
我正在使用 Apache Camel 的 Quartz 组件来运行一些预定路线。我想为调度程序配置 JDBC JobStore,并且能够在quartz 中设置必要的属性。
使用 Apache Camel 公开 Rest API - 收到 404
我尝试了非常简单的路线: 休息配置() .component("servlet"); 休息().get(“/你好”) .to(“直接:你好”); 来自(“直接...
从 Camel Rest DSL 生成 OpenAPI 时出错
我们最近将 apache Camel 从 3.x 升级到 4.x。从那时起 swagger 就不再工作了。请参阅 swagger ui 的附图。 启动应用程序时我们收到以下警告。 20...
上下文:我目前正在使用 Apache Camel 执行一些集成任务。我使用 Maven 编译代码,它为我提供了安装在 Apache Karaf 实例(v. 4.4.1)中的捆绑包。在...之上
camel-jms:共享持久订阅:参数subscriptionName转义点(.)
阿帕奇阿耳忒弥斯:2.31.2 弹簧启动:2.7.18 阿帕奇骆驼:3.22.0 我有一个关于 ActiveMQ Artemis 中 Camel 共享持久订阅的问题。 我已从 ActiveMQ Classic VirtualTopics 迁移,...
我正在尝试使用“camel-azure-storage-datalake-kafka-connector”从 Kafka 连接到 Azure ADLS Gen2 我有一个运行 Docker 的 Linux 机器,其中包含 debezium/zookeeper、debezium/kafka 和 debe...
将 CachedOutputStream 转换为字符串。 将camel从2.12升级到2.23后,我的路线出现问题,相同的代码相同的路线。 调用端点后的响应是 org.apache.camel 类型。
Camel/Quarkus - AdviceWith 无法通过 id 找到路线
我有以下路线: 来自(“直接:某些路线”) .id("一些路线") 。日志(...) .to("sql-stored:someProcedure(BIGINT ${exchangeProperty.someVal})") .id("someCall&...
我正在尝试构建一个 Java 应用程序,该应用程序从外部源(最好是数据库)加载 YAML DSL Camel 路由。这个想法是提供在外部编辑这些路线的可能性,刷新
使用 Apache Camel Servlet 组件获取状态为 404 的白标签页面
我正在使用 Camel 向其他系统提供 Web 服务。我编写了一个简单的 Camel 消耗路由来接受 http 请求。我可以使用 Springboot 成功启动 Camel 应用程序。但是...
Quartz 组件未在 Spring Boot 应用程序上调用驼峰处理器
我创建了具有以下依赖项的简单 JBossFUSE spring boot 应用程序 我创建了具有以下依赖项的简单 JBossFUSE spring boot 应用程序 <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>sample.fuse</groupId> <artifactId>sample-FUSE</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>war</packaging> <name>springboot-camel-restdsl-api</name> <description>Camel SpringBoot REST API Example with REST DSL</description> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.9.RELEASE</version> <relativePath /> <!-- lookup parent from repository --> </parent> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> <start-class>sample.fuse.UrarepSpringBootApplication</start-class> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> <exclusions> <exclusion> <groupId>org.apache.tomcat.embed</groupId> <artifactId>tomcat-embed-websocket</artifactId> </exclusion> </exclusions> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-spring-boot-starter</artifactId> <version>2.19.0</version> </dependency> <dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-servlet-starter</artifactId> <version>2.19.0</version> </dependency> <dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-jackson</artifactId> <version>2.19.0</version> </dependency> <dependency> <groupId>javax</groupId> <artifactId>javaee-api</artifactId> <version>7.0</version> </dependency> <dependency> <groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> </dependency> <dependency> <groupId>com.ibm.mq</groupId> <artifactId>mq-jms-spring-boot-starter</artifactId> <version>2.3.2</version> </dependency> <dependency> <groupId>com.ibm.mq</groupId> <artifactId>com.ibm.mq.allclient</artifactId> <version>9.2.0.0</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-artemis</artifactId> </dependency> <dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-quartz</artifactId> <version>2.13.0</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project> 然后我使用以下内容创建了简单的 RouteBuilder package sample.fuse.routebuilder; import com.fasterxml.jackson.core.JsonProcessingException; import org.apache.camel.Exchange; import org.apache.camel.LoggingLevel; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.model.rest.RestBindingMode; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import sample.fuse.process.*; import javax.ws.rs.core.MediaType; @Component public class MyRouteBuilder extends RouteBuilder { static Logger LOG = LoggerFactory.getLogger(MyRouteBuilder.class); @Autowired TestProcessor testProcessor; @Override public void configure() throws Exception { from("quartz://seasonParkingProcessorCron?cron=10+*+*+*+*+?&trigger.timeZone=America/Chicago&job.name=seasonParkingProcessorCron") .log(LoggingLevel.INFO, "seasonParkingProcessorCron job kicked off") .process(testProcessor); } } 示例处理器有以下内容。 package sample.fuse.process; import org.apache.camel.Exchange; import org.apache.camel.Processor; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.core.env.Environment; import org.springframework.stereotype.Component; import org.springframework.stereotype.Service; import sample.fuse.repository.MevEhtVideoImagesRepository; import java.util.Calendar; @Service @Component public class TestProcessor implements Processor { static Logger LOG = LoggerFactory.getLogger(TestProcessor.class); @Autowired Environment environment; @Autowired private MevEhtVideoImagesRepository mevEhtVideoImagesRepository; public TestProcessor(){ } @Override public void process(Exchange exchange) throws Exception { String body= (String) exchange.getIn().getBody(); LOG.info("TestProcessor Called with exchange: " + body); System.out.println("AAAAAAAAAAAAAa"); exchange.getOut().setBody(body+" "+ Calendar.getInstance().getTime()); } } 我希望每 10 秒调用一次 Processor 方法并打印日志。然而,它在日志上给出以下错误。 11:58:10,013警告[org.apache.camel.component.quartz.QuartzEndpoint](DefaultQuartzScheduler-camel-1_Worker-1)无法使用上下文执行Quartz作业:JobExecutionContext:触发器:'Camel.seasonParkingProcessorCron作业:DEFAULT.seasonParkingProcessorCron fireTime : 'Thu Dec 21 11:58:10 SGT 2023 ScheduleFireTime: Thu Dec 21 11:58:10 SGT 2023 previousFireTime: 'null nextFireTime: Thu Dec 21 11:59:10 SGT 2023 isRecovering: false refireCount: 0 因为处理器不是开始:RoundRobinLoadBalancer 还有其他人遇到过这种错误吗? 您必须为骆驼石英使用相同版本的骆驼核心版本。但是在你的pom文件中camel-core和camel-quartz版本应该匹配。 pom 文件中的camel-quartz 依赖项应更新如下 <dependency> <groupId>org.apache.camel</groupId> <artifactId>camel-quartz</artifactId> <version>2.19.0</version> </dependency> 然后你的MyRouteBuilder类配置方法内容需要更改如下。 from("quartz://seasonParkingProcessorCron?cron=10+*+*+*+*+?") .log(LoggingLevel.INFO, "seasonParkingProcessorCron job kicked off") .process(testProcessor); 希望这将有助于解决您的问题。
让 Apache Camel 与 Amazon S3 存储桶配合使用所需的最低权限是什么?
我正在尝试使用 Apache Camel + Amazon S3 制作一个应用程序。只是一个简单的情况,文件将由端点接收、处理并发送到 S3 存储桶。 s3.bucket=我的桶 c...
使用 Apache Camel 列出来自 Springboot 的 AWS S3 存储桶内容
我有一个运行 v2.5.4 的 sprintboot 项目,运行良好。 我可以访问 S3,并且可以列出我创建的存储桶的内容。所以我想尝试使用 Apache Camel 来尝试
编写 JUnit 4 测试类来测试 Apache Camel 路由
我有一个用于 cron 作业目的的 Maven 项目,我必须为测试类编写逻辑,以通过 JUnit 4 测试 Apache Camel 路由。该应用程序运行良好。我是...
我有一个用于 cron 作业目的的 Maven 项目,我必须为测试类编写逻辑,以通过 Junit4 测试 apache 骆驼路由。该应用程序运行完美。我先写...
我正在尝试使用过滤器在我的 Camel Route 中过滤来自 activeMQ 的消息,但当我使用 || 等运算符时,我无法使其工作。或者 && 所以基本上我收到了来自 acti 的消息...
在 Apache Camel 路由中调用通过 Bearer 令牌身份验证保护的其余 api
我需要从我的 Apache Camel 路由调用 Rest API。 Rest API 使用可在其他 API 上获取的令牌进行保护。 我的演示路线如下所示: 来自(“直接:物联网”)...