To who should I send these information? ________________________________ From: Andrea Cosentino <anco...@gmail.com> Sent: Monday, February 20, 2023 7:17 PM To: users@camel.apache.org <users@camel.apache.org> Subject: Re: Start a route with aggregation fails due to NPE in AggregateProcessor
You need, as reported in the link, to provide an email, a username and a display name. Il lun 20 feb 2023, 19:04 Andrea Cosentino <anco...@gmail.com> ha scritto: > Hello, > > Please follow the instructions here > https://infra.apache.org/jira-guidelines.html#who to create an account on > your behalf. > > Thanks > > Il lun 20 feb 2023, 19:03 Sydney Henrard <shenr...@smartwavesa.com> ha > scritto: > >> Hello Claus, >> >> Thanks for confirming. I wanted to create a ticket but I have no account. >> Would it be possible to create one? >> >> Thanks >> Sydney >> ________________________________ >> From: Claus Ibsen <claus.ib...@gmail.com> >> Sent: Saturday, February 18, 2023 8:03 PM >> To: users@camel.apache.org <users@camel.apache.org> >> Subject: Re: Start a route with aggregation fails due to NPE in >> AggregateProcessor >> >> Hi >> >> Yes that sounds plausible. So it would be good in the camel code, to check >> for null exchange >> >> On Sat, Feb 18, 2023 at 6:46 PM Sydney Henrard <shenr...@smartwavesa.com> >> wrote: >> >> > Hello, >> > >> > In my application I have a route with an aggregation using an >> aggregation >> > repository ClusteredJdbcAggregationRepository and completionTimeout. >> This >> > route is part of a micro service that can be scaled. From time to time, >> the >> > micro service does not start due to a NPE: >> > >> > Caused by: java.lang.NullPointerException: Cannot invoke >> > >> "org.apache.camel.Exchange.getProperty(org.apache.camel.ExchangePropertyKey, >> > Object, java.lang.Class)" because "exchange" is null >> > at >> > >> org.apache.camel.processor.aggregate.AggregateProcessor.restoreTimeoutMapFromAggregationRepository(AggregateProcessor.java:920) >> > ~[camel-core-processor-3.20.1.jar:3.20.1] >> > >> > Looking at the code in >> > >> https://github.com/apache/camel/blob/camel-3.20.1/core/camel-core-processor/src/main/java/org/apache/camel/processor/aggregate/AggregateProcessor.java#L920 >> > >> > In my case the exchange is null because it has already been processed by >> > one of the micro service instance. >> > >> > for (String key : keys) { >> > Exchange exchange = aggregationRepository.get(camelContext, key); >> > // grab the timeout value >> > long timeout = >> > exchange.getProperty(ExchangePropertyKey.AGGREGATED_TIMEOUT, 0L, >> > long.class); >> > >> > Is my assumption correct? >> > >> > Sydney >> > >> > >> > >> > >> > >> > >> >> -- >> Claus Ibsen >> ----------------- >> @davsclaus >> Camel in Action 2: https://www.manning.com/ibsen2 >> >
