To priv...@camel.apache.org They should have been in the email where you were requesting the account
Il lun 20 feb 2023, 19:29 Sydney Henrard <shenr...@smartwavesa.com> ha scritto: > 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 > >> > > >
