[
https://issues.apache.org/jira/browse/CAMEL-12668?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chirag Anand updated CAMEL-12668:
---------------------------------
Affects Version/s: (was: 2.22.0)
2.17.0
Description:
I have a camel project where I am using twitter component of the camel and
using the streaming/filter endpoint. The route is something like
from(<twitterstreamendpoint>).aggregate(<customstratergy>).completionSize().forceCompletionOnStop().process().
The problem here is when I stop the context the remaining aggregated exchanges
are not being flushed to the processor. Earlier I was using version 2.16.2 and
it worked fine, but with the latest release i.e 2.22.0 I am facing this issue.
The configuration hasn’t changed a bit. To be certain i tried it with version
2.17.0 also, doesn't work either.
I tried debugging and I noticed at somepoint there is a
RejectedExecutionException, not sure why because there is no change in the
configuration.
Can you please resolve this at the earliest? or at least tell me if there has
been any change in the functionality/usage?
was:
I have a camel project where I am using twitter component of the camel and
using the streaming/filter endpoint. The route is something like
from(<twitterstreamendpoint>).aggregate(<customstratergy>).completionSize().forceCompletionOnStop().process().
The problem here is when I stop the context the remaining aggregated exchanges
are not being flushed to the processor. Earlier I was using version 2.16.2 and
it worked fine, but with the latest release I am facing this issue. The
configuration hasn’t changed a bit.
I tried debugging and I noticed at somepoint there is a
RejectedExecutionException, not sure why because there is no change in the
configuration.
> Aggregate with forcecompleteonstop doesn't seem to be honored
> -------------------------------------------------------------
>
> Key: CAMEL-12668
> URL: https://issues.apache.org/jira/browse/CAMEL-12668
> Project: Camel
> Issue Type: Bug
> Components: camel-core
> Affects Versions: 2.17.0
> Reporter: Chirag Anand
> Priority: Major
> Fix For: 2.22.0
>
>
> I have a camel project where I am using twitter component of the camel and
> using the streaming/filter endpoint. The route is something like
> from(<twitterstreamendpoint>).aggregate(<customstratergy>).completionSize().forceCompletionOnStop().process().
> The problem here is when I stop the context the remaining aggregated
> exchanges are not being flushed to the processor. Earlier I was using version
> 2.16.2 and it worked fine, but with the latest release i.e 2.22.0 I am facing
> this issue. The configuration hasn’t changed a bit. To be certain i tried it
> with version 2.17.0 also, doesn't work either.
>
> I tried debugging and I noticed at somepoint there is a
> RejectedExecutionException, not sure why because there is no change in the
> configuration.
>
> Can you please resolve this at the earliest? or at least tell me if there has
> been any change in the functionality/usage?
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
