Apache Camel - передача файлов по определенному маршруту

Вам следует попробовать функцию pollEnrich в content-enricher

В разделе примеров вы можете найти пример файлов.

Ваш маршрут должен выглядеть примерно так (я работаю только с camel java dsl, поэтому это немного псевдокод xml):

<route>
    <from uri="direct:fileTransferRoute" />
        <pollEnrich uri="file://D:\\FTPTest?fileName=data.txt....." />
        <to uri="ftp://[email protected]:21/public_html/EnterpriseProject?password=password123#"/>
    </route>

Отредактировано:

вы должны сначала понять одну вещь: to производитель, а не потребитель <to uri="file://D:\\FTPTest?noop=true&amp;delay=2000" />

Что вы можете сделать,

@Autowired
private CamelContext context;// if you have more than one camel context use @Qualifier and wire by bean id


public void process(Exchange exchange) throws Exception {
    String body = exchange.getIn().getBody(String.class);
    String serviceName = exchange.getIn().getHeader(Constants.SERVICE_NAME).toString();
    context.startRoute(serviceName+Constants.NEXT_ROUTE_APPENDER);// here in nextroute you must give the routeid
}

ваш маршрут должен выглядеть

 <route id = "<value of serviceName+Constants.NEXT_ROUTE_APPENDER>" autoStartup = "false">
                <from uri="file://D:\\FTPTest..." />
                <onCompletion onFailureOnly="true">
                  <choice>
                    <when>
                        <simple>${property.CamelBatchComplete}</simple>
                    <process ref="asyncSelfShutdownProcessor"/>
                    </when>
                  </choice>
                </onCompletion>
                <to uri="ftp://[email protected]:21..."/>
            </route>

И добавьте asyncSelfShutdownProcessor в контекст Spring

@Component
public class AsyncSelfShutdownProcessor implements AsyncProcessor {

    @Autowired
    private CamelContext context

     public boolean process(Exchange exchange, AsyncCallback callback){

          new Thread(() -> context.stopRoute(exchange.getFromRouteId())).start();
     }
}

############################################ ############################# Старая версия:

<route id = "fs-to-ftp" autoStartup = "false">
            <from uri="file://D:\\FTPTest..." />
            <onCompletion onFailureOnly="true">
                <process ref="asyncSelfShutdownProcessor"/>
            </onCompletion>
            <to uri="ftp://[email protected]:21..."/>
        </route>

asyncSelfShutdownProcessor= AsyncProcessorConverterHelper.convert(exchange -> {
            new Thread(() -> context.stopRoute("fs-to-ftp")).start();
        });