Как я могу динамически записывать в разные папки в Camel, используя значение заголовка? - PullRequest
Новая
       13

Как я могу динамически записывать в разные папки в Camel, используя значение заголовка?

1 голос
/ 29 марта 2019

Мне нужно перенести файлы в несколько целевых систем.Эти целевые системы определены в имени файла из исходной системы.

Например: 

SLPNPM_ID0001_T20190329000000.DAT -> target directory : /SLPNPM/
SLPNP1_ID0001_T20190329000001.DAT -> target directory : /SLPNP1/
SLPNP2_ID0002_T20190329000002.DAT -> target directory : /SLPNP2/
...                                   ...

Итак, я реализовал приведенный ниже код.

CamelContext.xml 

    <route id="_route1">
      <from id="_from1" uri="direct:source"/>
      <bean id="_setTarget" ref="setTarget"/>
      <to id="_to1" uri="file:C:/{${header.targetNeId}}/outputFolder"/>
    </route>
    <bean id="setTarget" class="com.ktds.openmzn.sample.SetTarget"/>

SetTarget.java 

    public class SetTarget implements Processor {
     Logger logger = LoggerFactory.getLogger(SetTarget.class);
     @Override
     public void process(Exchange exchange) throws Exception {

    String target_neid = exchange.getIn().getHeader("CamelFileName").toString().substring(0, 6);
        //SLPNPM_FGIDRO01_ID0001_T20190312000500.DAT
        logger.info("Target Ne Id ::: " + target_neid);
        exchange.getIn().setHeader("targetNeId", target_neid);
     }

    }

Журнал ошибок 

Caused by: java.lang.IllegalArgumentException: Invalid directory: C:/{${header.targetNeId}}/outputFolder. Dynamic expressions with ${ } placeholders is not allowed. Use the fileName option to set the dynamic expression.
at org.apache.camel.component.file.FileComponent.buildFileEndpoint(FileComponent.java:57) ~[camel-core-2.23.1.jar:2.23.1]
at org.apache.camel.component.file.GenericFileComponent.createEndpoint(GenericFileComponent.java:56) ~[camel-core-2.23.1.jar:2.23.1]
at org.apache.camel.component.file.GenericFileComponent.createEndpoint(GenericFileComponent.java:38) ~[camel-core-2.23.1.jar:2.23.1]
at org.apache.camel.impl.DefaultComponent.createEndpoint(DefaultComponent.java:126) ~[camel-core-2.23.1.jar:2.23.1]
at org.apache.camel.impl.DefaultCamelContext.getEndpoint(DefaultCamelContext.java:706) ~[camel-core-2.23.1.jar:2.23.1]
... 39 common frames omitted

Как мне справиться с этим, если я хочу соответствовать требованиям своего бизнеса?

...