Re: Unable to setup route with limit of 30 queue size and 5 processing threads

[apara]

I think I am getting closer.  I replaced my exports back to direct:// and
re-implemented asyncHandle method by using my own pool:

...
    private final ExecutorService
        executor =
            Executors.newFixedThreadPool(20);

...

    @Override
    public Future<EventData> asyncHandle(final EventData data) throws
HandlerException {
        return
            executor
                .submit(
                    new Callable<EventData>() {
                        @Override
                        public EventData call() throws Exception {
                            return
                                handle(data);
                        }
                    }
                );
    }

Is this correct?  I was hoping to somehow being able to manage the pool from
Camel...

-AP_



--
View this message in context: 
http://camel.465427.n5.nabble.com/Unable-to-setup-route-with-limit-of-30-queue-size-and-5-processing-threads-tp5766520p5766538.html
Sent from the Camel - Users mailing list archive at Nabble.com.