Hi Valdis, I think you're looking for `channelPoolMaxSize` and `channelPoolMaxWait` parameters[1]. From the snippet, I guess, you would set them on the `feedbackEndpoint`, and from the message history I see that you already set the `connectionFactory`, so you would configure these much in the same way.
zoran [1] https://github.com/apache/camel/blob/master/components/camel-rabbitmq/src/main/docs/rabbitmq-component.adoc On Thu, Oct 4, 2018 at 6:15 PM, Valdis Andersons <valdis.anders...@vhi.ie> wrote: > Hi All, > > > > Would anyone know how to configure the timeout values for the below > connection pool or the connection pool itself? Been having some issues > lately in a test environment with this and the timeout check seems to happen > every few milliseconds producing huge amounts of log files. > > We’re suspecting it’s a network issue that’s causing this as there is > nothing much between the REST endpoint on the buffer queue and only if there > is some decent load on the endpoint (10req/sec or so): > > > > rest(restEndpoint).post(postEndpoint) > .type(FeedbackRequest.class) > .route() > .process(this::process) > .startupOrder(Integer.MAX_VALUE - 2) > .marshal().json(JsonLibrary.Jackson, String.class) > .to(feedbackEndpoint) > .endRest(); > > > > where process() just sets a persistence header for RabbitMQ to flush the > message to disk: > > > > exchange.getIn().setHeader("rabbitmq.DELIVERY_MODE", 2); > > > > > > 2018-10-04 17:01:43,275 [https-jsse-nio-8443-exec-65] ERROR > o.a.c.p.DefaultErrorHandler ID-VM1-1538665977944-0-101281 - Failed delivery > for (MessageId: ID-VM1-1538665977944-0-101280 on ExchangeId: > ID-VM1-1538665977944-0-101281). Exhausted after delivery attempt: 1 caught: > java.util.NoSuchElementException: Timeout waiting for idle object > > > > Message History > > --------------------------------------------------------------------------------------------------------------------------------------- > > RouteId ProcessorId Processor > Elapsed (ms) > > [route24 ] [route24 ] > [restlet:///cch/feedback?restletMethods=POST > ] [ 3798] > > [route24 ] [process22 ] [Processor@0x37c71429 > ] [ 0] > > [route24 ] [marshal1 ] > [marshal[org.apache.camel.model.dataformat.JsonDataFormat@c940d2] > ] [ 0] > > [route24 ] [route24 ] > [rabbitmq://vm1:5671/feedbackBufferExchange?connectionFactory=rabbitConnec] > [ 3782] > > > > Stacktrace > > --------------------------------------------------------------------------------------------------------------------------------------- > > java.util.NoSuchElementException: Timeout waiting for idle object > > at > org.apache.commons.pool.impl.GenericObjectPool.borrowObject(GenericObjectPool.java:1174) > > at > org.apache.camel.component.rabbitmq.RabbitMQProducer.execute(RabbitMQProducer.java:73) > > at > org.apache.camel.component.rabbitmq.RabbitMQProducer.basicPublish(RabbitMQProducer.java:285) > > at > org.apache.camel.component.rabbitmq.RabbitMQProducer.processInOnly(RabbitMQProducer.java:272) > > at > org.apache.camel.component.rabbitmq.RabbitMQProducer.process(RabbitMQProducer.java:195) > > at > org.apache.camel.processor.SendProcessor.process(SendProcessor.java:148) > > at > org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:548) > > at > org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) > > at > org.apache.camel.processor.Pipeline.process(Pipeline.java:138) > > at > org.apache.camel.processor.Pipeline.process(Pipeline.java:101) > > at > org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:201) > > at > org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:97) > > at > org.apache.camel.component.restlet.RestletConsumer$1.handle(RestletConsumer.java:68) > > at > org.apache.camel.component.restlet.MethodBasedRouter.handle(MethodBasedRouter.java:58) > > > > > > Thanks, > > Valdis > > > Vhi Group DAC (Vhi) is a holding company for insurance and healthcare > services, which include Vhi Healthcare DAC, Vhi Insurance DAC, Vhi Health > Services DAC and Vhi Investments DAC. Vhi Healthcare DAC trading as Vhi > Healthcare and Vhi Insurance DAC trading as Vhi Insurance are regulated by > the Central Bank of Ireland. Vhi Healthcare is tied to Vhi Insurance DAC for > health insurance in Ireland which is underwritten by Vhi Insurance DAC. Vhi > Healthcare is tied to Zurich Life Assurance plc for Vhi Life Term Insurance > and Vhi Mortgage Protection which is underwritten by Zurich Life Assurance > plc. Vhi Healthcare is tied to Collinson Insurance Services Limited for > MultiTrip Travel Insurance, Backpacker Travel Insurance and Vhi Dental > Insurance which are underwritten by Great Lakes Insurance SE, UK branch and > for Vhi Canada Cover and Vhi International Health Insurance which are > underwritten by Astrenska Insurance Limited. For more information about the > Vhi Group please go to: https://www.vhi.ie/about-vhi. > > > Tá Vhi Group DAC (Vhi) ina chuideachta sealbhaíochta le haghaidh seirbhísí > árachais agus seirbhísí cúram sláinte, lena n-áirítear Vhi Healthcare DAC, > Vhi Insurance DAC, Vhi Health Services DAC agus Vhi Investments DAC. Déanann > Banc Ceannais na hÉireann rialáil ar Vhi Healthcare DAC, ag trádáil dó mar > Vhi Healthcare, agus ar Vhi Insurance DAC, ag trádáil dó mar Vhi Insurance. > Tá Vhi Healthcare ceangailte le Vhi Insurance DAC le haghaidh árachas > sláinte in Éirinn, rud atá frithgheallta ag Vhi Insurance DAC. Tá Vhi > Healthcare ceangailte le Zurich Life Assurance plc le haghaidh Árachais > Saoil de chuid Vhi agus Árachas Cosanta Morgáiste de chuid Vhi atá > frithgheallta ag Zurich Life Assurance plc. Tá Vhi Healthcare ceangailte le > Collinson Insurance Services Limited le haghaidh Árachas Taistil Ilturais > agus Turasóirí Mála Droma agus Árachas Fiaclóireachta de chuid Vhi atá > frithgheallta ag Great Lakes Insurance SE, UK branch agus le haghaidh > Clúdach Cheanada de chuid Vhi agus Árachas Sláinte Idirnáisiúnta de chuid > Vhi atá frithgheallta ag Astrenska Insurance Limited. Chun tuilleadh > faisnéise a fháil faoi Ghrúpa Vhi, tabhair cuairt ar: > https://www.vhi.ie/about-vhi. > > This e-mail and any files transmitted with it contain information which may > be confidential and which may also be privileged and is intended solely for > the use of the individual or entity to whom it is addressed. Unless you are > the intended recipient you may not copy or use it, or disclose it to anyone > else. Any opinions expressed are that of the individual and not necessarily > that of the Vhi Group. If you have received this e-mail in error please > notify the sender by return. > > > > > > > > -- Zoran Regvart
