apache-camel

    0热度

    1回答

    我想知道是否有办法执行诸如System.out.println();之类的操作或记录发生了节流。目前我可以看到发生限制的唯一方法是将rejectExecution设置为True。问题是,如果它设置为true,那么请求不会在发生限制时被处理。有没有办法通知使用骆驼发生了限制?

    0热度

    1回答

    我有一个要求,我必须根据其内容动态地在目录上推文件。 与该目录相关的信息可在文件的第一行中找到。 由于文件的大小很大,加载文件的全部内容将不合适。 另外我想在读取第一行时跳过文件的其余部分。以下是我写 from("file:D:\\camel\\input?recursive=true&delete=true") .split().tokenize("'",1) .pr

    0热度

    2回答

    我想通过REST调用使用骆驼的路线从FTP下载文件集: 我想以下几点: from("cxfrs:bean:restndpoint") .pollEnrich("some ftp url") .to("destinationFilesLocation") .bean(MyBean.class); 它仅适用于一个文件在ftp上,当我试图运行它再一次它只是等待文件。如果我用(“某些ftp url”替换p

    1热度

    1回答

    这是我的system.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:amq="http://activemq.

    0热度

    2回答

    我正在基于webservice和jms队列的骆驼动态路由管理器。我有这个以下结构: endpoint:cxf -> jms:queue -> dynamic routing to a jms:queue -> processing 这里是我的路由定义: @Override public void configure() throws Exception { routeDefinit

    0热度

    1回答

    我开发了一个Java Camel项目,将文件从resources/data/inbox移动到SFTP服务器。 当我运行它,我得到这个消息: /usr/lib/jvm/jdk1.8.0_144/bin/java ...的log4j:警告没有附加目的地可能是 发现记录器(ORG .apache.camel.impl.DefaultCamelContext)。 log4j:WARN请正确初始化log4j

    0热度

    2回答

    我有骆驼Processor其开始Thread 此Processor实现弹簧ShutdownAware 当我发送TERM信号(正常关闭)到应用我没有收到任何有关以下信息 - 从ShutdownAware接口被调用的任何方法。 我提到过关于Thread,因为我想正确地阻止它。 import org.apache.camel.Processor; import org.apache.camel.spi

    1热度

    1回答

    我有一个全局定义的FTP骆驼路由。这是从另一个途径启动: exchange.getContext().startRoute("downloadRoute"); ,并在另一个线程停止,因为描述here: .process(new Processor() { Thread stop; @Override public void process(final Exchan

    0热度

    1回答

    我创建了2个不同的应用程序,并在其中一人开始了骆驼背景。如何在第二个应用程序中使用此已启动的上下文? 我尝试用lookUpByname获取上下文()与JNDI上下文结合的骆驼上下文,但是负载可以在现有的环境。 在应用1应用2上下文设置NameStrategy并得到同样也试过,但看起来像骆驼汽车在DefaultCamelContextNameStrategy生成名称和前缀。 code snippet

    1热度

    2回答

    目前,我们正在使用Apache-Camel为ETL,那就是,我们每天服用/来自不同数据库的每周/每月的出口,执行所需的操作,然后某处公布结果供其他数据库摄取。 最近我看到一个Apache-Airflow谈话,在我看来,它可以做的工作,骆驼是只是做容易。更容易我的意思是它看起来会更自我记录,因此更容易维护。我对么?而为什么两者之间没有比较,就像Camel and Mule之间有比较?