apache-camel 相关问题

如何在 Camel 4 / Spring 3 / Spring Boot 6 中使用 CachingConnectionFactory

对于Camel 3，以下配置有效 Camel.component.spring-rabbitmq.connection-factory=org.springframework.amqp.rabbit.connection.CachingConnectionFactory 使用 CachingConnectionFac...

Apache Camel 简单解析异常

我有一个 apache 骆驼路由，它从映射条目（一个 int）中获取密钥，并在该密钥在列表中时进行选择。但我遇到了例外 .`when`(简单("\${body.key} in [123,...

Apache Camel - 仅当队列大小大于

我试图找到仅当消息数大于一定数量时才消费JMS队列中的消息的方法。 有任何想法吗？ 通常如果您使用语法： 来自（“jms：开始曲...

Camel：生成多条路线，等待所有路线完成

在 Camel 路线中，我使用分离器来生成多个子路线。每一条路由都会使用一些外部 API 来完成一些工作，并轮询直到工作完成。我就这么远了 现在我需要触发...

在少数情况下，由于 toD(url) 导致 json 不完整

我正在使用 apache Camel 并从另一个系统拥有的数据湖中获取数据。 虽然在大多数情况下，这个流程工作得绝对正常，但对于极少数事件，我观察到

Apache Camel 项目 - 通知/监听 sql

Apache Camel项目中是否可以使用触发器函数读取表中新插入的数据？ 我正在使用 Apache Camel 和 PostgresDB 并在数据库中创建了触发器函数。特...

消息消费者每1秒关闭一次

我使用AMQP Camel从队列A读取消息，向消息添加标头并发送到主题B。每300毫秒队列A中就会有200条消息。根据日志文件，JMS

camel支持Kafka消费者的事务吗？

需要有从kafka读取事务路由->保留在db中->发布到MQ。 所有这一切都应该在一个事务中发生，如果 DB 或 Commit to MQ/JMS 失败，那么 kafka 消息不应该是

camel-observation-starter 使用完整请求数据创建指标

我有一个使用 Camel 的 Spring Boot 3 项目。我正在使用 org.apache.camel.springboot:camel-observation-starter 进行跟踪。 我已经使用自动配置说明和来自

Camel BeanIO 替代品

我知道在camel BeanIO 3.16版本之后已被弃用并从camel中删除。 我似乎找不到替代品。 我看到有些人编写自己的代码来替换它，但我很......

使用 JBang 在本地运行 Camel K jdbc

我正在尝试使用以下配置在本地使用jdbc运行camel-k。 集成 DSL KamelKJdbcRouter.java： 导入 org.apache.camel.builder.RouteBuilder; // 骆驼-k: dependency=camel:jdbc...

实现轮询第 3 方 API 并更新数据库的计划作业的有效方法

我有一个 Spring boot 应用程序，它有一个每 1.5 秒运行一次的计划作业。其目标是从第 3 方 API 获取数据，用结果更新数据库（如果需要）并重复。下一个 API...

如何为camel核心xml解析器启用AccessExternalSchema

在 https://camel.apache.org/manual/camel-3x-upgrade-guide-3_21.html 中发现，camel-core 禁用了对 xml 解析器的外部架构的访问。 我目前在camel r中遇到这个错误...

Apache Camel：无法找到 xsd 文件异常

我有以下 XML 文件： 我有以下 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:jaxrs="http://cxf.apache.org/jaxrs" xmlns:context="http://www.springframework.org/schema/context" xmlns:cxf="http://cxf.apache.org/core" xmlns:camel="http://camel.apache.org/schema/spring" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.5.xsd http://cxf.apache.org/jaxrs http://cxf.apache.org/schemas/jaxrs.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://cxf.apache.org/core http://cxf.apache.org/schemas/core.xsd http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring-2.9.0.xsd "> 每当我启动网络应用程序时，都会出现以下错误： Apr 19, 2012 3:10:59 PM org.springframework.util.xml.SimpleSaxErrorHandler warning WARNING: Ignored XML validation warning org.xml.sax.SAXParseException: schema_reference.4: Failed to read schema document 'http://camel.apache.org/schema/spring/camel-spring-2.9.0.xsd', because 1) could not find the document; 2) the document could not be read; 3) the root element of the document is not <xsd:schema>. at com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.createSAXParseException(Unknown Source) at com.sun.org.apache.xerces.internal.util.ErrorHandlerWrapper.warning(Unknown Source) at com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(Unknown Source) at com.sun.org.apache.xerces.internal.impl.XMLErrorReporter.reportError(Unknown Source) at com.sun.org.apache.xerces.internal.impl.xs.traversers.XSDHandler.reportSchemaErr(Unknown Source) at com.sun.org.apache.xerces.internal.impl.xs.traversers.XSDHandler.reportSchemaWarning(Unknown Source) at com.sun.org.apache.xerces.internal.impl.xs.traversers.XSDHandler.getSchemaDocument(Unknown Source) at com.sun.org.apache.xerces.internal.impl.xs.traversers.XSDHandler.parseSchema(Unknown Source) at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaLoader.loadSchema(Unknown Source) at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.findSchemaGrammar(Unknown Source) at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.handleStartElement(Unknown Source) at com.sun.org.apache.xerces.internal.impl.xs.XMLSchemaValidator.startElement(Unknown Source) at com.sun.org.apache.xerces.internal.impl.XMLNSDocumentScannerImpl.scanStartElement(Unknown Source) at com.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl$FragmentContentDriver.next(Unknown Source) at com.sun.org.apache.xerces.internal.impl.XMLDocumentScannerImpl.next(Unknown Source) at com.sun.org.apache.xerces.internal.impl.XMLNSDocumentScannerImpl.next(Unknown Source) at com.sun.org.apache.xerces.internal.impl.XMLDocumentFragmentScannerImpl.scanDocument(Unknown Source) at com.sun.org.apache.xerces.internal.parsers.XML11Configuration.parse(Unknown Source) at com.sun.org.apache.xerces.internal.parsers.XML11Configuration.parse(Unknown Source) at com.sun.org.apache.xerces.internal.parsers.XMLParser.parse(Unknown Source) at com.sun.org.apache.xerces.internal.parsers.DOMParser.parse(Unknown Source) at com.sun.org.apache.xerces.internal.jaxp.DocumentBuilderImpl.parse(Unknown Source) at org.springframework.beans.factory.xml.DefaultDocumentLoader.loadDocument(DefaultDocumentLoader.java:75) at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.doLoadBeanDefinitions(XmlBeanDefinitionReader.java:388) at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:334) at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:302) at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:143) at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:178) at org.springframework.beans.factory.support.AbstractBeanDefinitionReader.loadBeanDefinitions(AbstractBeanDefinitionReader.java:149) at org.springframework.web.context.support.XmlWebApplicationContext.loadBeanDefinitions(XmlWebApplicationContext.java:124) at org.springframework.web.context.support.XmlWebApplicationContext.loadBeanDefinitions(XmlWebApplicationContext.java:93) at org.springframework.context.support.AbstractRefreshableApplicationContext.refreshBeanFactory(AbstractRefreshableApplicationContext.java:130) at org.springframework.context.support.AbstractApplicationContext.obtainFreshBeanFactory(AbstractApplicationContext.java:467) at org.springframework.context.support.AbstractApplicationContext.refresh(AbstractApplicationContext.java:397) at org.springframework.web.context.ContextLoader.createWebApplicationContext(ContextLoader.java:282) at org.springframework.web.context.ContextLoader.initWebApplicationContext(ContextLoader.java:204) at org.springframework.web.context.ContextLoaderListener.contextInitialized(ContextLoaderListener.java:47) at org.apache.catalina.core.StandardContext.listenerStart(StandardContext.java:4323) at org.apache.catalina.core.StandardContext.startInternal(StandardContext.java:4780) at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:139) at org.apache.catalina.core.ContainerBase.startInternal(ContainerBase.java:988) at org.apache.catalina.core.StandardHost.startInternal(StandardHost.java:771) at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:139) at org.apache.catalina.core.ContainerBase.startInternal(ContainerBase.java:988) at org.apache.catalina.core.StandardEngine.startInternal(StandardEngine.java:275) at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:139) at org.apache.catalina.core.StandardService.startInternal(StandardService.java:427) at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:139) at org.apache.catalina.core.StandardServer.startInternal(StandardServer.java:649) at org.apache.catalina.util.LifecycleBase.start(LifecycleBase.java:139) at org.apache.catalina.startup.Catalina.start(Catalina.java:585) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) at java.lang.reflect.Method.invoke(Unknown Source) at org.apache.catalina.startup.Bootstrap.start(Bootstrap.java:288) at org.apache.catalina.startup.Bootstrap.main(Bootstrap.java:415) Apr 19, 2012 3:10:59 PM org.springframework.web.context.ContextLoader initWebApplicationContext SEVERE: Context initialization failed org.springframework.beans.factory.xml.XmlBeanDefinitionStoreException: Line 81 in XML document from ServletContext resource [/WEB-INF/Beans.xml] is invalid; nested exception is org.xml.sax.SAXParseException: cvc-complex-type.2.4.c: The matching wildcard is strict, but no declaration can be found for element 'camelContext'. at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.doLoadBeanDefinitions(XmlBeanDefinitionReader.java:396) at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:334) at org.springframework.beans.factory.xml.XmlBeanDefinitionReader.loadBeanDefinitions(XmlBeanDefinitionReader.java:302) at ..... 我不明白为什么会发生这种情况。另外，如果这是由于某些互联网连接问题造成的，为什么我没有得到 cxf xsd 异常？ 第一个解释不相关，因为 .xsd 存在于此处： http://camel.apache.org/schema/spring/camel-spring-2.9.0.xsd 检查您的 XML 文档。还有一个问题。 发布整个堆栈跟踪是彻底的，但没有必要。 XSD 在依赖项中提供。您应该验证您的类路径，您需要版本 2.9。您还可以使用通用位置来获取可用的位置： http://camel.apache.org/schema/spring http://camel.apache.org/schema/spring/camel-spring.xsd 对于那些从 3.19.x 迁移到 3.22.x 的人来说，这是一个救星。 这解决了camel-config.xml中丢失的xsd文件 camel-spring.xsd 在camel-spring-3.10.0.jar 中丢失

Apache Karavan 集成 Whatsapp 消息

我已经生成了一个 yaml，使用 apache karavan 在 Whatsapp 上每 10 秒发送一次消息，但是我在哪里输入收件人电话号码？我也找不到任何有关它的文档 这是我的...

使用 Camel 导出 CSV 中的键值对

我正在尝试使用 Camel CSV 文档将 java 对象导出到 CSV 文件中。我可以看到例子 Map body = new HashMap(); body.put("foo", "abc"); 博...

Swagger 对 Apache Camel 4 的支持

我正在从 Apache Camel 3.20.x 升级到 4.x.x，发现 Camel 3 支持的camel-swagger-java（版本 3.20.x）不受 Camel 4 支持。图书馆还没有

Apache Camel Cron 作业调度

刚接触 Apache Camel，我有一个要求，需要每五分钟查找一个文件夹并将文件从源移动到目标。我写了下面的代码，但是当我运行作业时它是警察......

Apache Camel 2.17.3 - 使用 bindy 解组 CSV 流时出现异常

我编写了一个简单的路线来读取 CSV 文件并将其保存在 JSON 格式的新文件中。 当我尝试拆分和流式传输正文时，解组会因“.IllegalArgumentException：没有记录 h...

pollEnrich 正在内存中加载文件并导致 EKS 部署中出现堆错误

我们有一个应用程序，它使用来自SQS的消息并根据sqs消息将文件从s3下载到文件系统。 我们使用 apache Camel 来轮询 SQS 消息队列并丰富，然后将文件下载到