[jira] [Commented] (CAMEL-12668) Aggregate with forcecompleteonstop doesn't seem to be honored
[ https://issues.apache.org/jira/browse/CAMEL-12668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16579287#comment-16579287 ] Chirag Anand commented on CAMEL-12668: -- [~dmvolod] This helps, i am able to capture the inflight exchanges. Can you please provide me with the details of the new issue which you will open? I would like to keep a track of it. > 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 >Assignee: Dmitry Volodin >Priority: Major > Fix For: 2.22.1 > > > 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().aggregate().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)
[jira] [Commented] (CAMEL-12668) Aggregate with forcecompleteonstop doesn't seem to be honored
[
https://issues.apache.org/jira/browse/CAMEL-12668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16570231#comment-16570231
]
Chirag Anand commented on CAMEL-12668:
--
[~dmvolod] Can you please provide me with a code snippet on how to shutdown the
route? i tried context.shutdownRoute("Routeid"), it still failed with the same
exception.
> 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
>Assignee: Dmitry Volodin
>Priority: Major
> Fix For: 2.22.1
>
>
> 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().aggregate().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)
[jira] [Commented] (CAMEL-12668) Aggregate with forcecompleteonstop doesn't seem to be honored
[ https://issues.apache.org/jira/browse/CAMEL-12668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16564999#comment-16564999 ] Chirag Anand commented on CAMEL-12668: -- [~dmvolod] Please try with the repo [https://github.com/chirag0103/CamelForceCompletionOnStopTest]. This is a maven project and much cleaner. You can change the camel version from pom.xml, currently i have set it to 2.17.0 > 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 >Assignee: Dmitry Volodin >Priority: Major > Fix For: 2.22.1 > > > 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().aggregate().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)
[jira] [Commented] (CAMEL-12668) Aggregate with forcecompleteonstop doesn't seem to be honored
[ https://issues.apache.org/jira/browse/CAMEL-12668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16563775#comment-16563775 ] Chirag Anand commented on CAMEL-12668: -- [~dmvolod] The reproducer code seems to be fine except can you use an empty file instead or increase the completionsize to a larger value? You can look at [https://github.com/chirag0103/CamelAggregationFailure] for reference. Please tell me if you need any other information. > 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 >Assignee: Dmitry Volodin >Priority: Major > Fix For: 2.22.1 > > > 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().aggregate().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)
[jira] [Commented] (CAMEL-12668) Aggregate with forcecompleteonstop doesn't seem to be honored
[
https://issues.apache.org/jira/browse/CAMEL-12668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554378#comment-16554378
]
Chirag Anand commented on CAMEL-12668:
--
[~dmvolod] I have tried the same scenario with camel-stream component using the
same aggregation logic. It succeeded for version 2.16.2 but when i am using
2.17.0 it fails again. The route i am using is as follows -
from("stream:file?fileName=C:/Test/ABC.txt")
.aggregate(constant(true), new CamelAggregator()).completionSize(50)
.forceCompletionOnStop().process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
List statusObjects =
exchange.getIn().getBody(List.class);
System.out.println(statusObjects.size());
}
}).end();
Can we please fix it at the earliest now? It's very important that this gets
fixed soon.
> 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().aggregate().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)
[jira] [Commented] (CAMEL-12668) Aggregate with forcecompleteonstop doesn't seem to be honored
[
https://issues.apache.org/jira/browse/CAMEL-12668?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16554012#comment-16554012
]
Chirag Anand commented on CAMEL-12668:
--
Hi [~dmvolod], Thank you for responding. I tried the same thing using file
component and it seemed to work fine but doesn't work when using the twitter
component. I am testing this with Camel version 2.17.0.
The route that i am using for twitter component is as such -
public class CamelRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
from("twitter://streaming/filter?accessToken=xxx=xxx=xxx=xxx=XYZ=event")
.aggregate(constant(true), new
CamelAggregator()).completionSize(50)
.forceCompletionOnStop().process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
List statusObjects =
exchange.getIn().getBody(List.class);
System.out.println(statusObjects.size());
}
}).end();
}
}
The custom aggregation logic is as such -
public class CamelAggregator implements AggregationStrategy {
@Override
public Exchange aggregate(Exchange oldExchange, Exchange newExchange) {
Object newBody = newExchange.getIn().getBody(Object.class);
List list = null;
if (oldExchange == null) {
list = new ArrayList<>();
list.add(newBody);
newExchange.getIn().setBody(list);
return newExchange;
} else {
list = oldExchange.getIn().getBody(ArrayList.class);
list.add(newBody);
return oldExchange;
}
}
}
The route which succeeded for the file component is as such -
public class CamelFileRoute extends RouteBuilder {
@Override
public void configure() throws Exception {
from("file://C:/Test")
.aggregate(constant(true), new CamelAggregator()).completionSize(50)
.forceCompletionOnStop().process(new Processor() {
@Override
public void process(Exchange exchange) throws Exception {
List statusObjects =
exchange.getIn().getBody(List.class);
System.out.println(statusObjects.size());
}
}).end();
}
}
Please tell me if i am making any mistake here or if there is any problem with
the twitter component only?
> 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().aggregate().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)
[jira] [Updated] (CAMEL-12668) Aggregate with forcecompleteonstop doesn't seem to be honored
[ 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().aggregate().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().aggregate().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().aggregate().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)
[jira] [Created] (CAMEL-12668) Aggregate with forcecompleteonstop doesn't seem to be honored
Chirag Anand created CAMEL-12668: Summary: 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.22.0 Reporter: Chirag Anand 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().aggregate().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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
[jira] [Commented] (CAMEL-11510) The consumer endpoint for Twitter component timeline/user doesn't poll the tweets even if the type is set to polling and delay attribute doesn't work
[ https://issues.apache.org/jira/browse/CAMEL-11510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16073599#comment-16073599 ] Chirag Anand commented on CAMEL-11510: -- Also tried using the version 2.19.0, didn't work. Can you help me out here? > The consumer endpoint for Twitter component timeline/user doesn't poll the > tweets even if the type is set to polling and delay attribute doesn't work > - > > Key: CAMEL-11510 > URL: https://issues.apache.org/jira/browse/CAMEL-11510 > Project: Camel > Issue Type: Bug > Components: camel-twitter >Affects Versions: 2.16.2 > Environment: Any machine >Reporter: Chirag Anand >Priority: Minor > > When we try to get the tweets from timeline of a user using the consumer > endpoint timeline/user of the Twitter component. It only gets first set of > Tweets 20 tweets at max and later doesn't poll for the rest of them even > though the type is given as polling. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (CAMEL-11510) The consumer endpoint for Twitter component timeline/user doesn't poll the tweets even if the type is set to polling and delay attribute doesn't work
[ https://issues.apache.org/jira/browse/CAMEL-11510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16073558#comment-16073558 ] Chirag Anand commented on CAMEL-11510: -- I did try with 2.18.1 too. It doesn't work either. > The consumer endpoint for Twitter component timeline/user doesn't poll the > tweets even if the type is set to polling and delay attribute doesn't work > - > > Key: CAMEL-11510 > URL: https://issues.apache.org/jira/browse/CAMEL-11510 > Project: Camel > Issue Type: Bug > Components: camel-twitter >Affects Versions: 2.16.2 > Environment: Any machine >Reporter: Chirag Anand >Priority: Minor > > When we try to get the tweets from timeline of a user using the consumer > endpoint timeline/user of the Twitter component. It only gets first set of > Tweets 20 tweets at max and later doesn't poll for the rest of them even > though the type is given as polling. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Created] (CAMEL-11510) The consumer endpoint for Twitter component timeline/user doesn't poll the tweets even if the type is set to polling and delay attribute doesn't work
Chirag Anand created CAMEL-11510: Summary: The consumer endpoint for Twitter component timeline/user doesn't poll the tweets even if the type is set to polling and delay attribute doesn't work Key: CAMEL-11510 URL: https://issues.apache.org/jira/browse/CAMEL-11510 Project: Camel Issue Type: Bug Components: camel-twitter Affects Versions: 2.16.2 Environment: Any machine Reporter: Chirag Anand Fix For: 2.16.2 When we try to get the tweets from timeline of a user using the consumer endpoint timeline/user of the Twitter component. It only gets first set of Tweets 20 tweets at max and later doesn't poll for the rest of them even though the type is given as polling. -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Updated] (CAMEL-11182) SolrParams are not honored when sending SolrInputDocument.
[ https://issues.apache.org/jira/browse/CAMEL-11182?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chirag Anand updated CAMEL-11182: - Description: I have an update Processor chain which triggers during every update of the solr document which requires SolrParams to be passed. I noticed SolrParams is not applicable when trying to push SolrInputDocument(referring to SolrProducer.java). Can i submit a fix for this? (was: I have an update Processor chain which triggers during every update of the solr document which requires SolrParams to be passed. I noticed SolrParams is not applicable when trying to push SolrInputSocument(referring to SolrProducer.java). Can i submit a fix for this? ) > SolrParams are not honored when sending SolrInputDocument. > -- > > Key: CAMEL-11182 > URL: https://issues.apache.org/jira/browse/CAMEL-11182 > Project: Camel > Issue Type: Improvement > Components: camel-solr >Affects Versions: 2.18.3 > Environment: Apache Solr , Apache Camel >Reporter: Chirag Anand > > I have an update Processor chain which triggers during every update of the > solr document which requires SolrParams to be passed. I noticed SolrParams is > not applicable when trying to push SolrInputDocument(referring to > SolrProducer.java). Can i submit a fix for this? -- This message was sent by Atlassian JIRA (v6.3.15#6346)
