apache-camel 相关问题

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

如何使用Apache Camel读取OneDrive目录?

我希望能够自动从One-drive链接,或者从SharePoint在线读取文件。我曾看到一个参考使用Camel-CMIS使用Apache Camel CMIS与Sharepoint 2013似乎......

回答 1 投票 0

在Camel Route中读取收到的MQTT主题。

我正在尝试配置一个Apache Camel Spring Route,我想从MQTT中消耗消息并打印它们的主题。我想从MQTT中消耗消息,并打印它们的主题。我如何获得消息被发布到的主题?我正在使用...

回答 2 投票 1

如何使用Apache Kafka实现 "精确一次 "的kafka消费者?

我们有一个应用程序,它从Kafka主题(3个分区)中消耗消息,并丰富数据并将记录保存在DB中(Spring JPA),然后将消息发布到另一个Kafka主题(......

回答 1 投票 0

注册Apache Camel处理器的监听器

我试图将在Apache Camel处理器中处理的数据推送给一个监听器类。在处理器类实例中,我试图在Camel上下文实例化的过程中注册监听器,但不知为何 ...

回答 1 投票 0

org.apache.camel.main.Main在哪里?

我正在使用Camel,并试图了解如何在没有Spring的情况下使用它。我找到了几个例子1和2。但是当我尝试导入org.apache.camel.main.Main时,我什么也没得到。我使用的是Java...

回答 2 投票 0

Camel xslt组件从给定的xml数据中创建静态sql查询。

我想使用 camel xslt 组件从 xml 数据中创建一个 sql 查询。我已经尝试使用xsl文件(从xml文件创建)使用xslt组件创建html页面。但是没有足够的信息......我认为最简单的方法是使用xsl文件(从xml文件中创建)创建html页面。

回答 1 投票 0

hazelcast mapstore不能与多个成员一起持续存在

我在使用MapStore和Hazelcast时遇到了一个奇怪的问题。我已经实现了一个MapStore,并将其持久化到数据库中。当我启动Hazelcast应用程序时,我有两个成员。当我的客户程序...

回答 1 投票 0

Apache文件组件--如果文件不存在,则抛出错误。

下面的代码在文件存在的情况下读取文件的内容,但是如果文件不存在,那么它就会卡在那一行。如何才能抛出一个错误或出来 "file:/"语句,如果 ...

回答 1 投票 0

Apache Camel测试expectedBodiesReceived检查body是否为空?

我有一个路由,一个处理器消耗消息并将body设置为null。 public class KafkaRedirect implements Processor { @Override public void process(final Exchange exchange) throws ...

回答 1 投票 0

在AWS中托管Apache Camel的最佳方式是什么?

随着我们将工作负载转移到AWS上,我正在寻找一个广泛使用的ETL工具,它具有适当的连接器--Apache Camel似乎符合要求。然而,我正在努力寻找... ...

回答 1 投票 0

没有找到direct:/DistributeOrderXML的端点,请检查您的classpath中是否包含所需的Camel组件jar。

DistributeOrderXML.java public static void main(String[] args) throws Exception{ ApplicationContext appContext = new ClassPathXmlApplicationContext("SpringRouteContext.xml"); CamelContext ...

回答 1 投票 0

骆驼文件组件无法使用多线程进行并行消费。

我有一个目录,文件通过骆驼路由被推送到这个目录。从同一个目录中,我需要多个线程来消耗文件并处理它们。

回答 1 投票 0

如何在其他maven项目中使用一个maven项目的属性?

我有两个独立的项目--第一个项目(主项目)被添加到第二个项目(fietounzip)中作为依赖,我不能把它们作为模块,因为使用第一个项目(主项目)的maven项目数量是 ...

回答 1 投票 0

通过骆驼分词器和尾部分词器获得文件中的第一行。

我想获得巨大文件的第一行。为此,我做了.tokenize("\n", 1).choice().when(simple("${property.CamelSplitIndex} == 0")).log("header month :: ${body}").endChoice()这样的操作。

回答 1 投票 1

利用Eclipse与Red Hat Codeready(Fuse集成)为Wildfly应用服务器开发。

我对Red Hats Fuse工具有点con-fuse-d。下面是我想做的。用Eclipse(2020-03)设计Camel Routes 然后把它们部署到Wildfly服务器上(16或18) 用wildfly-...

回答 1 投票 0

使用Camel Endpoint DSL与@EndpointInject创建不同的端点。

使用端点DSL,然后用ProducerTemplate引用端点的正确方法是什么?当创建一个路由并使用端点DSL时,Camel似乎正在为该路由创建一个不同的uri ...

回答 1 投票 0

使用apache-camel[2.24.3]消费SOAP服务时出错。

当我试图使用部署在Jboss EAP 7.1和我的服务器上的Apache camel[2.24.3]和部署在Weblogic12c中的spring[5.2.2.RELEASE]的SOAP服务时,我收到了错误。在...

回答 1 投票 0

在使用Apache Camel进行编排时,如何返回我的API异常?

我在一个项目中使用了Apache Camel 我需要在它抛出异常时返回我调用的API响应。 ...

回答 1 投票 1

当路由到一个路由时产生的Apache Camel异常。

我对spring-boot和apache camel很陌生。我正试图创建一个应用程序,它将调用一个休息的端点,我在本地使用Camel进行路由。当我运行这个应用程序时,我得到...

回答 1 投票 0

使用Apache camel将MyObject传递给Bean路由的可能性?

我正在使用apache camel JAVA DSLs从Apache kafka消耗消息。我正在写一个对象,通过在kafka上将其转换为字节[]。当我消耗它时,我有一个消息返回字节[],我反序列化...

回答 3 投票 0

最新问题
© www.soinside.com 2019 - 2024. All rights reserved.