java - Camel :pollEnrich和访问交易所

我有这条路

from(URI_WEBSERVICE)
.convertBodyTo(Entrada.class)
.process(new ProcessorTratarWS())
.pollEnrich("ftp://10.100.8.2/entradaCamel?username=USER&password=PASSWORD&delete=true&fileName=${property.archivoRespuesta}", timeOut, new EstrategiaConfirmacion())
.to(WS_RESPONDER)

在ProcessorTratarWS（）中，我设置了property.archivoRespuesta的值，并且是pollEnrich应该卸载的文件的名称。

但是，文档显示“ PollEnrich无法访问Exchange”。这意味着PollEnrich无法读取$ {property.archivoRespuesta}的值

我正在尝试使用Camel做其他事情吗？

谢谢！

最佳答案

来自http://camel.apache.org/content-enricher.html


  ...
  您可以使用收件人列表并动态地代替收件人使用充实
  端点并在收件人列表上定义一个AggregationStrategy
  然后可以像富人一样工作。 ...


尝试类似：

from(URI_WEBSERVICE)
.convertBodyTo(Entrada.class)
.process(new ProcessorTratarWS())
.recipientList(simple("ftp://10.100.8.2/entradaCamel?username=USER&password=PASSWORD&delete=true&fileName=${property.archivoRespuesta}")).aggregationStrategy(new EstrategiaConfirmacion())
.to(WS_RESPONDER)

编辑：

上面的代码是将文件保存在FTP服务器中。
如果要从FTP服务器轮询文件，可以尝试

        from(URI_WEBSERVICE)
            .convertBodyTo(Entrada.class)
            .process(new Processor() {
                @Override
                public void process(Exchange exchange) throws Exception {
                    // logic of ProcessorTratarWS goes here
                    ConsumerTemplate consumer=exchange.getContext().createConsumerTemplate();
                    String filename=exchange.getProperty("archivoRespuesta",String.class);
                    Object file=consumer.receiveBody("ftp://10.100.8.2/entradaCamel?username=USER&password=PASSWORD&delete=true&fileName="+filename,timeOut);
                    // logic of EstrategiaConfirmacion goes here
            }

        })
        .to(WS_RESPONDER);

免责声明：我没有使用过polling consumer，可能会有更优雅/更有效的解决方案