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

Reply via email to