apache-camel 相关问题

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

使用 oneToMany 解组将平面文件传输到 Pojo 不起作用

我使用 http://camel.apache.org/bindy.html 有以下测试程序 问题是代码能够将 pojo 结构编组到平面 CSV 文件中,但无法将文件数据解组回 p...

回答 3 投票 0

Apache Camel:通往同一路线的多条路线

我想将消息从更多路由路由到同一条路由,但它不能按我假设的方式工作。我设置了以下内容(我只是放下本质): 来自(“直接:a”)[......

回答 2 投票 0

有没有办法在apache Camel中使用全局属性

我有一个调度程序,每 10 分钟将一些值(N 或 Y)放入主题中(通常为“N”,除非主题发生异常)。当主题下降时,调度程序将填充一个pr...

回答 3 投票 0

Apache Camel 支持带有 Java 注释的 BeanIO v3 吗?

根据 https://camel.apache.org/components/4.8.x/dataformats/beanio-dataformat.html,映射文件目前是必需的。

回答 1 投票 0

无法在 Apache Camel AS2 库中发送消息特定的签名 MDN 响应

我在我的 Java 项目中使用 Apache Camel AS2 库,在该项目中我实现了 AS2 服务器。 目前,我通过在

回答 1 投票 0

将springframework库从5.x.x升级到6.x.x后无法加载camel-context.xml

我刚刚将 springframework 依赖项从 5.3.34 升级到 6.1.14,我的代码在运行时抛出错误。这些是我的依赖项: org.springframework 我刚刚将 springframework 依赖项从 5.3.34 升级到 6.1.14,我的代码在运行时抛出错误。 这些是我的依赖项: <dependency> <groupId>org.springframework</groupId> <artifactId>spring-core</artifactId> <version>${spring-version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-web</artifactId> <version>${spring-version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-tx</artifactId> <version>${spring-version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-aop</artifactId> <version>${spring-version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-beans</artifactId> <version>${spring-version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>${spring-version}</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-expression</artifactId> <version>${spring-version}</version> </dependency> 我有这行代码加载我的camel-context.xml(它破坏了): ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("camel-context.xml"); 这是我的camel-context.xml 的一小部分(精简版): <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd"> <camelContext id="camel" xmlns="http://camel.apache.org/schema/spring"> <routeBuilder ref="deleteReportRoute"></routeBuilder> </camelContext> </beans> 当我运行代码时,它会因以下错误而中断: org.springframework.beans.factory.BeanDefinitionStoreException: Unexpected exception parsing XML document from class path resource [camel-context.xml] at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.doLoadBeanDefinitions(XmlBeanDefinitionReader.java:426) at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:347) at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:319) at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:184) at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:220) at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:191) at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:253) at org.springframework.context.support.AbstractXmlApplicationContext.loadBeanDefinitions(AbstractXmlApplicationContext.java:130) at org.springframework.context.support.AbstractXmlApplicationContext.loadBeanDefinitions(AbstractXmlApplicationContext.java:95) at org.springframework.context.support.AbstractRefreshableApplicationContext.refreshBeanFactory(AbstractRefreshableApplicationContext.java:131) at org.springframework.context.support.AbstractApplicationContext.obtainFreshBeanFactory(AbstractApplicationContext.java:714) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:596) at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:144) at org.springframework.context.support.ClassPathXmlApplicationContext.<init>(ClassPathXmlApplicationContext.java:85) at com.verint.textanalytics.dataexportservice.common.applicationContext.ApplicationContextManager.getContext(ApplicationContextManager.java:40) at com.verint.textanalytics.dataexportservice.service.MainApp.loadLocalization(MainApp.java:135) at com.verint.textanalytics.dataexportservice.service.MainApp.main(MainApp.java:55) Caused by: org.springframework.beans.FatalBeanException: Unresolvable class definition for NamespaceHandler class [org.apache.camel.spring.handler.CamelNamespaceHandler] for namespace [http://camel.apache.org/schema/spring] at org.springframework.beans.factory.xml.DefaultNamespaceHandlerResolver.resolve(DefaultNamespaceHandlerResolver.java:144) at org.springframework.beans.factory.xml.BeanDefinitionParserDelegate.parseCustomElement(BeanDefinitionParserDelegate.java:1385) at org.springframework.beans.factory.xml.BeanDefinitionParserDelegate.parseCustomElement(BeanDefinitionParserDelegate.java:1370) at org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentReader.parseBeanDefinitions(DefaultBeanDefinitionDocumentReader.java:179) at org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentReader.doRegisterBeanDefinitions(DefaultBeanDefinitionDocumentReader.java:150) at org.springframework.beans.factory.xml.DefaultBeanDefinitionDocumentReader.registerBeanDefinitions(DefaultBeanDefinitionDocumentReader.java:96) at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.registerBeanDefinitions(XmlBeanDefinitionReader.java:520) at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.doLoadBeanDefinitions(XmlBeanDefinitionReader.java:400) ... 16 more 有几点需要注意: 我所有的 springframework 依赖项都有相同的版本 我在 camel-spring 版本的主 pom.xml 中也有 3.6.0 依赖项。也尝试将其升级到最新版本,但这没有帮助 如果我从我的 <camelContext> 中删除 camel-context.xml 标签,项目运行不会出现错误,但服务不会侦听任何端点 你不能只是将 spring 从 5 升级到 6 而不升级 Camel。相反,您将 Camel 升级到支持 Spring 6 的版本。

回答 1 投票 0

消费者未从队列中获取消息

我有一个 osgi 包,其中有一些骆驼路线。现在暂时一切正常。一段时间后,其中一条路由停止接收消息。消息被发送到队列,但路由...

回答 1 投票 0

使用 Spring、Camel 和 Atomikos 进行 ActiveMQ.Advisory.Consumer.Queue 主题泛洪

我想知道是否有人在使用Atomikos + Camel + ActiveMQ Classic的组合时遇到过这个问题。我正在使用这个组合以事务处理方式从队列中剥离消息。它

回答 1 投票 0

Camel Kafka -consumersCount 和 groupInstanceId

将 Apache Camel 配置为 Apache Kafka 的使用者时,您可以设置许多配置选项,包括与此问题相关的以下选项: 组实例 ID。消费者数量。

回答 1 投票 0

Apache Camel Rest DSL OpenAPI 生成器

基于示例,我在 Apache Camel Spring Boot 项目中创建了以下 REST 端点并发布了 OpenAPI 规范: 根据示例,我在 Apache Camel Spring Boot 项目中创建了以下 REST 端点并发布了 OpenAPI 规范: <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd"> <camelContext xmlns="http://camel.apache.org/schema/spring"> <restConfiguration component="servlet" apiContextPath="/api-docs"> </restConfiguration> <rest path="/say"> <get path="/hello"> <to uri="direct:hello"/> </get> <get path="/bye" consumes="application/json"> <to uri="direct:bye"/> </get> <post path="/bye"> <to uri="mock:update"/> </post> </rest> </camelContext> </beans> 目前,当我访问以下网址:/api/api-docs时,我收到以下响应: "openapi" : "3.0.0" 从中可以清楚地看出 OpenAPI 规范正在版本 3.0 中生成 我正在使用Apache Camel 4.9.0-SNAPSHOT。 是否可以配置Camel生成2.0版本的OpenAPI规范? 不,它不像詹姆斯在上面的评论中所写的那样

回答 1 投票 0

将 Apache-Camel 3 与 Guice 结合使用

我有一个使用 Apache-Camel 和 Guice 的 java 应用程序。我正在尝试从 Apache-camel v2 升级到 v3 以支持 JDK17。我看到camel-guice 包已被弃用并从camel 3 中删除。我...

回答 1 投票 0

将 Apache Camel 路由打印到 Java DSL

有没有办法在Java DSL中打印路由? 我找到了一种在 XML DSL 中打印 Camel 路线的方法: ModelHelper.dumpModelAsXml(camelContext,routeDefinition); 或者在 YAML DSL 中使用: 模型编写者(

回答 1 投票 0

如何设置camel Http组件的最大连接数

我使用servlet和camel rest dsl来定义路由。 我没有在我的应用程序中使用 xml 文件。 如何使用 http 组件选项设置 http 组件的最大连接数?

回答 2 投票 0

将 AdviceWith 与 Kotlin 和 Quarkus 结合使用

我正在尝试为我的骆驼路线编写测试。我将 Kotlin 与 Quarkus 一起使用。 正如我所意识到的,CamelContext 尝试在我自己的 RouteBuilder 之前使用我的生产路线运行 AdviceWithRouteBuilder,所以

回答 1 投票 0

有没有办法在不抛出异常的情况下中止路由单的处理?

我有一个包含几个步骤的路由表。我希望能够包含执行一些验证的步骤,这些验证可以在需要时短路路由表。 我有: 来自(“直接:开始...

回答 2 投票 0

Spring Boot 中的 apache Camel 错误,文件camel-routes.yml

我在 Spring Boot 中使用了 apache Camel 的应用程序,并且路由被配置到具有 2 个处理器的 Camel-routes.yml 中。 pom: 17 ...

回答 1 投票 0

如何使用 Apache Camel Netty4 以异步模式通过已建立的 TCP 连接发回响应?

我正在构建一个微服务,它在消费者模式下使用 Netty4 组件 (http://camel.apache.org/netty4.html) 具有 Apache Camel 路由。所以,在我的微服务中,我正在构建的这条路线将

回答 2 投票 0

java.lang.IllegalArgumentException:在支持文件扩展名的类路径中找不到 RoutesBuilderLoader:xml

在 JDK 和 Spring boot 升级过程中进行依赖项升级时遇到问题。 目前我正在将 JDK 和 Spring boot 版本从 JDK-1.8 和 2.7.2 迁移到 JDK-17 和 3.2.11。同时

回答 1 投票 0

directoryName 选项不适用于 AzureDataLake Camel 消费者

我正在尝试在java中设置骆驼路线,读取Azure数据湖中的csv并对其进行处理。到目前为止,它看起来像这样: 来自(“直接:更新值”) .pollEnrich() .s...

回答 1 投票 0

Apache Camel 中的默认 RoutePolicy

我有以下场景 路由策略: @Slf4j @RequiredArgsConstructor 公共类 LoggingPolicy 扩展 RoutePolicySupport { 私人最终字符串问候语; @覆盖 公共空间

回答 1 投票 0

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