Thanks for your reply.
So, just want to confirm - no need to put the start() and stop() for each
thread, is that correct?
And, our application will be running for ever (untill we manually kill the
process), so I am not sure where to put the stop() method. Any suggestions?
Thanks again,
Shylendran.C
On Tue, Oct 20, 2015 at 1:06 AM, Claus Ibsen <claus.ib...@gmail.com> wrote:
> Dont start / stop it all the time, create it once and reuse it, and
> stop it when you stop your app.
>
> On Tue, Oct 20, 2015 at 6:17 AM, shylendran.c <shylendra...@gmail.com>
> wrote:
> > Hi,
> > I am using camel-code-2.15.2.jar. I have a multi-threaded application
> where
> > I have to send message continuously and I am using
> > org.apache.camel.ProducerTemplate. But since it is a multi-threaded, it
> is
> > breaking and getting the below exceptions. So, I've tried with 'static
> > synchronized' where everything is working, but we can't go with 'static
> > synchronized'. So looking for a solution.
> > It is clear that the exception is happening when we have
> > ProducerTemplate.start() and stop() when multi-threads are invoking
> this. We
> > have created only one instance of ProducerTemplate.
> >
> > Is there a way which I can check whether the producer template is already
> > 'open' or 'stop'. I see few protected variables, and while debugging I
> see
> > exactly what I am looking.
> > Please let me know your opinion on this.
> >
> > class RMThread implements Runnable {
> >
> > .......
> > .........
> > public void run() {
> > if (producerTemp != null) {
> >
> > producerTemp.start();
> > producerTemp.sendBodyAndHeaders("zzzz", "", map);
> > producerTemp.stop();
> > .....
> > ......
> > }
> > }
> >
> > public class MainClass {
> > ....
> > ProducerTemplate producerTemplate = null;
> > producerTemplate = configureRoutes.getContext().createProducerTemplate();
> >
> > ServerSocket ss = new ServerSocket(111
> > while (true) {
> > new Thread(new RMThread(ss.accept(), log, producerTemplate,
> > producerTemplate_sendTransferMetrics)).start();
> > ....
> > }
> >
> >
> > Exceptions::
> > org.apache.camel.CamelExecutionException: Exception occurred during
> > execution on the exchange: Exchange[Message: ]
> > at
> >
> org.apache.camel.util.ObjectHelper.wrapCamelExecutionException(ObjectHelper.java:1635)
> > ....
> > Caused by: java.lang.IllegalStateException: Pool not open
> > at
> >
> org.apache.commons.pool.BaseObjectPool.assertOpen(BaseObjectPool.java:140)
> > ...
> > ....
> >
> > Thanks,
> > Shylendran.C
> >
> >
> >
> >
> > --
> > View this message in context:
> http://camel.465427.n5.nabble.com/ProducerTemplate-creates-too-much-threads-tp5751299p5772885.html
> > Sent from the Camel - Users mailing list archive at Nabble.com.
>
>
>
> --
> Claus Ibsen
> -----------------
> http://davsclaus.com @davsclaus
> Camel in Action 2nd edition:
> https://www.manning.com/books/camel-in-action-second-edition
>
