- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
我想运行一个简单的 Apache Camel将文件从一个目录复制到另一个目录的示例:
CamelContext context = new DefaultCamelContext();
context.addRoutes(new RouteBuilder() {
public void configure () throws Exception {
from("file://c:/fromdir/").to("file://c:/todir/");
}
});
context.start();
如果我使用 Apache Camel 2.0.0 运行此示例,程序会在 context.start();
之后立即退出,并且什么都不做。如果我在 CamelContext
开始后添加 Thread.sleep(30000);
,后台线程会完成它们的工作,并且文件会从源目录复制到目标目录 30秒。
但是,如果我使用 Apache Camel 1.6.2 运行相同的代码,start()
方法会自动阻塞,我不需要让主线程 hibernate 来复制文件.我还没有发现此行为从 Camel 1.x 更改为 2.x 的提示。这真的是预期的行为吗?是否可以让 start() 方法在 Camel 2.0.0 中阻止执行?
谢谢
最佳答案
或者你可以添加
Thread.currentThread().join();
在 context.start() 之后;
关于java - CamelContext.start() 不会阻塞,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/1846791/
我一直在使用ApacheCamel连接到ftp/sftp,但是当(ftp/sftp的)凭据无效时,我发现当我调用CamelContext时camel不会抛出任何异常。 start() 方法来路由。那么
我正在使用 Spring + Apache Camel 示例。在前面的示例中,我使用的是 camel-core version 2.15.1。现在我刚刚将依赖项更新为 2.17.3 当我更新依赖项时,
我想知道CamelContext何时启动。正如我所见,DefaultCamelContext 有 private Date startDate 字段。没有 getter 或其他方法可以从此字段获取信息
在我的应用程序中,我想使用 application.properties 中的 someData 填充端点 url,并彻底填充 header.name 和 header.myId在使用 myEndpo
我的camel-server.xml 和 Spring 集成遇到某种配置问题。 我创建了一个名为camel-server.xml的文件,其中包含Camel在使用SpringBoot运行部署应用程序时所
我们使用 Java DSL 来配置我们的路由。路由的所有配置都在数据库表中,可以通过 GUI 进行配置。 即使路由配置错误(例如路由中的 .to(invalidurl or typo) 或者只是一个错
我正在尝试手动加载CamelContext来自applicationContext.xml文件如下所示:
我想运行一个简单的 Apache Camel将文件从一个目录复制到另一个目录的示例: CamelContext context = new DefaultCamelContext(); context
这可能是一个简单的错误配置问题,但我的 xml 文档选取我的标签时遇到了问题。我收到错误 “在此行发现多个注释: - cvc-complex-type.2.4.c: 匹配的通配符是严格的,但找不到元素
我正在尝试通过camel cdi使用org.apache.activemq.pool.PooledConnectionFactor初始化ActiveMQComponent。使用ActiveMQConn
是否可以为每个端点而不是每个CamelContext声明拦截器?就我而言,我有很多 CamelContext,我想将带有端点声明和拦截器的公共(public)代码提取到一个文件:camel-commo
eip-conext.xml: MyProcess.java: public void
当 CamelContext 停止时,我如何获得通知,API 有 addStartupListener 但在上下文停止时没有类似的东西? 最佳答案 Camel 邮件列表上也有人问过这个问题 http:
我有以下要求: 路线 1:from(timer:foo?repeatcount=1).recepientList("rest service") 路线 2:from(sourcequeue).proc
我正在循环中执行CamelContext.addRoutes(),最后如果我检查CamelContext.getRoutes().size(),它会返回0,直到上下文启动。 仅在添加任何路由时才启动上
我正在使用RabbitMQ component Camel,用于 Camel 路由。从 RabbitMQ 控制台创建队列时,我没有明确提及任何交换名称。但该网址需要 exchangeName rabb
我使用 Camel 2.14.1 将消息路由到一堆端点,例如: from(...) ... .to(monitoringEndpointId, broadcastEndpointId); 我想在运行时
嗨,请原谅我的知识不足,但我是使用 spring 和 camel 的初学者。我正在尝试制作一个简单的 camelContext bean,它将消息从端点路由到另一个名为 smartlighting 的
我对 Spring 和 Camel 有疑问。 很抱歉我无法粘贴真实代码...因此,我正在尝试使用占位符获取在 Camel 上下文中定义的属性。但属性为空。 .... Some fantasti
我正在使用带有 spring boot 2.2.6 的 camel 3.1.0。我有外部化配置,spring cloud bus 被用来从 Git 读取配置数据。 当我启动应用程序时,它通过 spri
我是一名优秀的程序员,十分优秀!