小编Eri*_*ong的帖子

我在测试类中配置了一个简单的路由，如下所示：

import org.apache.camel.builder.RouteBuilder;
import org.apache.camel.component.mock.MockEndpoint;
import org.apache.camel.test.junit4.CamelTestSupport;
import org.junit.Test;

public class TestClass extends CamelTestSupport {   
    String ftpSourceUri = "ftp://some.server.com:21?username=user&password=secret&fileName=test.csv";


    @Test
    public void testRouteConsumesTestFileFromFTPEndpoint() throws Exception{
        MockEndpoint mock = getMockEndpoint("mock:result");
        mock.expectedMinimumMessageCount(1);
        assertMockEndpointsSatisfied();
    }

    @Override
    protected RouteBuilder createRouteBuilder() throws Exception {
        return new RouteBuilder() {

            @Override
            public void configure() throws Exception {
                from(ftpSourceUri)
                .multicast().to("mock:result","stream:out");

            }
        };
    }
}

我已经通过 FileZilla 验证了身份验证详细信息和文件位置。

这是我执行上述代码时骆驼产生的跟踪片段：

[main] DefaultCamelContext INFO Apache Camel 2.14.0（CamelContext：camel-1）正在启动 [
main] DefaultManagementStrategy INFO JMX 已禁用 [
main] DefaultTypeConverter INFO 已加载 192 个类型转换器 [main] …