java - maximumreconnectattempts - github camel examples

Tiempo de espera simple de la ruta FTP en camello

Question

Hola, soy nuevo en camello y camel-ftp tan desnudo conmigo. Configuré una ruta simple dentro de una clase de prueba ver a continuación:

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");

            }
        };
    }
}

He validado los detalles de autenticación y la ubicación del archivo a través de FileZilla.

Este es el fragmento de rastreo producido por camello cuando ejecuto el código anterior:

[main] DefaultCamelContext INFO Apache Camel 2.14.0 (CamelContext: camel-1) está comenzando [
main] DefaultManagementStrategy INFO JMX está deshabilitado [
main] DefaultTypeConverter INFO Cargado 192 type converters [main] DefaultCamelContext INFO AllowUseOriginalMessage está habilitado. Si no se necesita acceso al mensaje original, se recomienda desactivar esta opción ya que puede mejorar el rendimiento. [main] DefaultCamelContext INFO StreamCaching no está en uso. Si se utilizan flujos, se recomienda habilitar el almacenamiento en caché de secuencias. Ver más detalles en [main] DefaultCamelContext
INFO Ruta: ruta1 iniciada y consumida desde: Punto final [''url punto final''] <- No puedo publicar más de 2 enlaces aparentemente [
main] DefaultCamelContext INFO Total 1 rutas, de las cuales 1 se inicia. [main] DefaultCamelContext
INFORMACIÓN Apache Camel 2.14.0 (CamelContext: camel-1) iniciado en 0.140 segundos [main] MockEndpoint
INFO Afirmación: El punto final [simulacro: // resultado] está satisfecho [tal-music-ftp.amazonmp3.com:21] FtpConsumer INFO Conectado y conectado a: [''endpoint url''] <- No puedo publicar más de 2 enlaces aparentemente [principal] AmazonMP3SimpleFTPRouteTest INFO ****************************************** ************************************** [main] AmazonMP3SimpleFTPRouteTest INFO Prueba realizada: testRouteConsumesTestFileFromFTPEndpoint (com. test.camel.SimpleFTPRouteTest) [main] AmazonMP3SimpleFTPRouteTest INFO Tomó: 10.010 segundos (10010 millis) [main] AmazonMP3SimpleFTPRouteTest INFO ************************** ************************************************** **** [main] DefaultCamelContext INFO Apache Camel 2.14.0 (CamelContext: camel-1) está cerrando [
main] DefaultShutdownStrategy INFO Comenzar a cerrar graciosamente 1 rutas (tiempo de espera 10 segundos) [el-1) thread # 1 - ShutdownTask] DefaultShutdownStrategy INFO En espera ya que todavía quedan 1 en vuelo y cambios pendientes para completar, timeout en 10 segundos. [el-1) thread # 1 - ShutdownTask] DefaultShutdownStrategy
INFO En espera, ya que aún quedan 1 intercambio en vuelo y pendientes para completar, agote el tiempo de espera en 9 segundos. [el-1) thread # 1 - ShutdownTask] DefaultShutdownStrategy INFO En espera ya que aún quedan 1 en vuelo y cambios pendientes para completar, timeout en 8 segundos. [el-1) thread # 1 - ShutdownTask] DefaultShutdownStrategy INFO En espera ya que todavía quedan 1 en vuelo y cambios pendientes para completar, expira en 7 segundos. [el-1) thread # 1 - ShutdownTask] DefaultShutdownStrategy INFO En espera ya que todavía quedan 1 en vuelo y cambios pendientes para completar, agote el tiempo en 6 segundos. [el-1) thread # 1 - ShutdownTask] DefaultShutdownStrategy INFO En espera ya que todavía quedan 1 en vuelo y cambios pendientes para completar, timeout en 5 segundos. [el-1) thread # 1 - ShutdownTask] DefaultShutdownStrategy INFO En espera ya que aún quedan 1 en vuelo y cambios pendientes para completar, agote el tiempo en 4 segundos. [el-1) thread # 1 - ShutdownTask] DefaultShutdownStrategy INFO En espera ya que aún quedan 1 en vuelo y cambios pendientes para completar, expira en 3 segundos. [el-1) thread # 1 - ShutdownTask] DefaultShutdownStrategy INFO En espera ya que todavía quedan 1 en vuelo y cambios pendientes para completar, agote el tiempo en 2 segundos. [el-1) thread # 1 - ShutdownTask] DefaultShutdownStrategy INFO En espera, ya que todavía hay 1 en vuelo y pendientes de intercambios para completar, el tiempo de espera en 1 segundos. [main] DefaultShutdownStrategy WARN Tiempo de espera ocurrido. Forzar las rutas a ser cerradas ahora. Algunos recursos aún pueden estar en ejecución. [el-1) thread # 1 - ShutdownTask] DefaultShutdownStrategy WARN Interrumpido mientras se esperaba durante el apagado correcto, forzará el cierre ahora. [el-1) thread # 1 - ShutdownTask] DefaultShutdownStrategy INFO Ruta: finalización de route1 completa, consumía desde: Endpoint [''url de punto final''] <- No puedo publicar más de 2 enlaces aparentemente [principal] DefaultShutdownStrategy INFO Cierre agraciado de 1 rutas completadas en 52 segundos [
main] DefaultCamelContext INFO Apache Camel 2.14.0 (CamelContext: camel-1) uptime 1 minuto [
main] DefaultCamelContext INFO Apache Camel 2.14.0 (CamelContext: camel-1) se apaga en 52.486 segundos

¿Qué puedo hacer para simplemente descargar el archivo?

Answer 1

El MockEndpoint tendrá un tiempo de espera predeterminado después de 10 segundos desde la prueba de la unidad. Por lo tanto, debe establecer un tiempo de espera más alto para que el FTP descargue y procese el archivo.

Puede pasar un valor de tiempo de espera en, por ejemplo

assertMockEndpointsSatisfied(5, TimeUnit.MINUTES);