Hi,
I have created a unit test to test a file uri with stream :
Here is the url used
stream:url:file:///./target/stream/scanstreamfile.txt?scanStream=true&scanStreamDelay=100
but it does not work. Error occurs during the doStop() execution because no
executor has been created at this line
executor =
ExecutorServiceHelper.newSingleThreadExecutor(endpoint.getEndpointUri(),
true);
What is strange is that when the following method is called
private InputStream resolveStreamFromUrl() throws IOException {
String u = endpoint.getUrl();
ObjectHelper.notEmpty(u, "url");
if (LOG.isDebugEnabled()) {
LOG.debug("About to read from url: " + u);
}
the url returned by endpoint.getUrl() is null
Regards,
Charles Moulliard
Senior Enterprise Architect
Apache Camel Committer
*****************************
blog : http://cmoulliard.blogspot.com
