我正在测试我的应用程序，该应用程序将文件从ftp发送到我的计算机，并且正在检查不要将一个文件复制两次。为此，我使用IdempotentConsumer。
我的问题是我无法运行测试，因为此IdempotentConsumer总是给我错误。
如何解决？
类
@Component
public class Converter extends SpringRouteBuilder {
@Override
public void configure() throws Exception {
final XmlJsonDataFormat xmlJsonFormat = new XmlJsonDataFormat();
xmlJsonFormat.setTypeHints(String.valueOf("YES"));
from("ftp://Mike@localhost?" +
"noop=true&binary=true&consumer.delay=5s&include=.*xml")
.idempotentConsumer(header("CamelFileName"), FileIdempotentRepository.fileIdempotentRepository(new File("data", "repo.dat")))
.marshal(xmlJsonFormat).to("file://data").process(
new Processor() {
//System.out.println();
}
});
}
}
测试班
public class ConverterTest extends CamelTestSupport {
@Override
protected RouteBuilder createRouteBuilder() throws Exception {
return new Converter();
}
@Test
public void testAdvisedMockEndpoints() throws Exception {
context.getRouteDefinitions().get(0).adviceWith(context, new AdviceWithRouteBuilder() {
@Override
public void configure() throws Exception {
replaceFromWith("direct:inputXML");
interceptSendToEndpoint("file://data")
.skipSendToOriginalEndpoint()
.to("mock:outXML");
}
});
context.start();
getMockEndpoint("mock:outXML").expectedMessageCount(1);
template.sendBody("direct:inputXML", "Test data");
assertMockEndpointsSatisfied();
}
}
我收到以下错误：
org.apache.camel.CamelExecutionException: Exception occurred during execution on the exchange: Exchange[Message: Test data]
Caused by: org.apache.camel.processor.idempotent.NoMessageIdException: No message ID could be found using expression: header(CamelFileName) on message exchange: Exchange[Message: Test data]
最佳答案
如果启动上下文，通常ftp组件会添加CamelFileName标头。
但是由于您是在测试中使用直接注入消息的，因此可能并非如此。
尝试通过使用.setHeader("CamelFileName", constant("msg01.txt"))手动添加标题来适应您的测试。