apache-camel

0热度

1回答

发送数据到Wildfly 10嵌入的Artemis实例并接收它们使用Apache Camel

我试图发送一些数据到Wildfly 10 Artemis实例并使用Apache Camel接收它们。在这里，我知道，这可以使用camel-jms组件完成。在这种情况下，我首先创建了一个简单的示例来检查这是否工作正常。但是，它在ConnectionFactory创建点处给出了以下例外。 Exception in thread "main" javax.naming.NamingExceptio

0热度

2回答

动态Apache骆驼输出路由

嗨，我想要使用apache骆驼计算动态输出路由。我在文件夹位置收到一堆文件，根据其内容我想将文件移动到动态输出文件夹。输出文件夹的名称将根据文件的输入内容构建。我如何实现它。下面这段代码读取文件，处理它们，但我不知道如何设置的$ {文件夹名}基于文件的内容价值 from("file:D:\\camel\\input\\one?recursive=true&delete=true")

0热度

1回答

限制Camel CometD端点的协议

是否可以限制Camel CometD端点或一般端点允许使用哪些协议？例如，我想限制端点，以便它只能通过websockets接收呼叫，而不允许HTTP。

0热度

1回答

如何显示驼峰发生节流

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

0热度

1回答

Apache Camel只读第一行

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

0热度

2回答

下载集从FTP与骆驼的文件通过REST调用

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

1热度

1回答

如何测试在Apache的骆驼（春季）路线

这是我的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回答

log4j：WARN无法找到记录器的appender（org.apache.camel.impl.DefaultCamelContext）

我开发了一个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回答

组合[弹簧] DefaultShutdownStrategy的，[骆驼] ShutdownAware和[骆驼处理器不工作

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