我用的是Apache Camel 2.11.1
有这样的路线:
from("file:///somewhere/").
threads(20).
to("direct:process")
有一段时间,我得到了一个异常:带有消息的org.apache.camel.InvalidPayloadException
No body available of type: java.io.InputStream but has value: GenericFile[/somewhere/file.txt] of type:
org.apache.camel.compo
我有下面的代码,从windows系统读取文件,并将其放置在ibm-mq中。我没有收到任何错误。但是当我检查IBM队列中的消息时,我没有收到任何消息。 public class FileToJMS{
public static void main(String args[]) throws Exception
{
final Map headers=new HashMap();
headers.put("xxx","yy");
headers.put("yyy","zzz
下面是我的骆驼执行组件的代码。这是我第一次使用Camel,我只是想让骆驼执行执行一个批处理文件给我。有人能告诉我我是如何配置workingDir参数的吗?作为错误的一部分,我得到了无法设置的1个参数。如果有关系的话,我在修窗户。
import org.apache.camel.CamelContext;
import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.impl.DefaultCamelContext;
/**
* A Camel Java DSL Router
*/
public class My
我正致力于在一个文件夹上创建一个自动轮询,我的路由是在spring XML文件中设置的,我如何才能保持应用程序在该文件夹上运行和轮询,我可以使用常规路由在java中输入它们作为from to,但现在由于使用XML route spring,我无法创建路由构建器或添加一个。我的主线是
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.apache.camel.main.Main;
public class FileTransferinSpring {
public
我正在尝试通过SFTP获取大文件,并尝试使用readLocks。当尝试获取1G文件(一个需要几秒钟才能复制的大文件)时,我得到了以下异常。顺便说一句,当我尝试一个1M量级的小文件时,SFTP工作正常。
这是Camel 2.12.1中的一个bug,还是我做错了什么?
2013-12-13 14:30:12,964 [alhost/outbound] INFO SftpConsumer - Connected and logged in to: sftp://tdr@localhost:22
2013-12-13 14:30:19,893 [alhost/ou
我正在使用Apache Camel来构建代理。我能够运行所提供的示例。但是我必须手动配置camel-config.xml文件。我想知道我们是否可以在运行时以编程方式配置这个文件来托管/配置代理?
这是原始的camel-config.xml文件:
<?xml version="1.0" encoding="UTF-8"?>
<!--
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements.
我需要通过sftp连接到ftp服务器。我成功地通过ftp和ftps与camel连接。
public static RouteBuilder getRouteBuilderSFTPS() {
return new RouteBuilder() {
public void configure() {
from("sftp://666.66.666.66:22/POLP-FROAKS?fileName=testMsg.txt&username=POLP-FROAKS&password=pass&s
我最近在合并了一个不相关的更改后遇到了Camel的情况,这导致了堆栈跟踪:
java.lang.reflect.InvocationTargetException
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingM
我试图在一个模块使用camelot-test:run的-based多模块项目上执行目标
$ mvn clean compile camelot-test:run
.... (a lot of output)
org.springframework.beans.factory.BeanInitializationException: Cannot initialize plugins system: config not found! Paths=[]
at ru.yandex.qatools.camelot.core.impl.GenericPluginsEngine.loadConf