FAQ
I want to do something like this:

from("activemq:start)
.transacted()
.aggregate(new PMCAggregationStrategy())
.constant(true) // aggregate everything into one message
.completionPredicate(header(FINISH_AGGREGATION).isEqualTo(true))
.to("mock:end");

Since aggregation can take long time, I want to make sure no messages
are lost on Camel restart. But it seems that it's losing messages that
are currently being aggregated. Where does transaction end for multiple
messages being aggregated like this ? Does each have it's own
transaction and the transaction is somehow saved along the route ?

Persistence works fine for routes that don't have aggregation.
For example :

from("activemq:worksfine)
.transacted()
.process(..)
.delay(...)
.to("mock:end");

In this case, on Camel restart, the messages will be picked from
ActiveMQ and re-processed.





--
Dragisa Krsmanovic
Java Developer
Public Library of Science
http://www.plos.org


--------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
This email is confidential to the intended recipient. If you have received it in error, please notify the sender and delete it from your system. Any unauthorized use, disclosure or copying is not permitted. The views or opinions presented are solely those of the sender and do not necessarily represent those of Public Library of Science unless otherwise specifically stated. Please note that neither Public Library of Science nor any of its agents accept any responsibility for any viruses that may be contained in this e-mail or its attachments and it is your responsibility to scan the e-mail and attachments (if any).

Search Discussions

  • Claus Ibsen at Nov 11, 2009 at 6:10 pm
    Hi

    The aggregator in Camel does not yet support persistence.
    Its on the roadmap for Camel 2.2.


    On Wed, Nov 11, 2009 at 5:58 PM, Dragisa Krsmanovic
    wrote:
    I want to do something like this:

    from("activemq:start)
    .transacted()
    .aggregate(new PMCAggregationStrategy())
    .constant(true) // aggregate everything into one message
    .completionPredicate(header(FINISH_AGGREGATION).isEqualTo(true))
    .to("mock:end");

    Since aggregation can take long time, I want to make sure no messages
    are lost on Camel restart. But it seems that it's losing messages that
    are currently being aggregated. Where does transaction end for multiple
    messages being aggregated like this ? Does each have it's own
    transaction and the transaction is somehow saved along the route ?

    Persistence works fine for routes that don't have aggregation.
    For example :

    from("activemq:worksfine)
    .transacted()
    .process(..)
    .delay(...)
    .to("mock:end");

    In this case, on Camel restart, the messages will be picked from
    ActiveMQ and re-processed.





    --
    Dragisa Krsmanovic
    Java Developer
    Public Library of Science
    http://www.plos.org


    --------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------
    This email is confidential to the intended recipient. If you have received it in error, please notify the sender and delete it from your system. Any unauthorized use, disclosure or copying is not permitted. The views or opinions presented are solely those of the sender and do not necessarily represent those of Public Library of Science unless otherwise specifically stated. Please note that neither Public Library of Science nor any of its agents accept any responsibility for any viruses that may be contained in this e-mail or its attachments and it is your responsibility to scan the e-mail and attachments (if any).


    --
    Claus Ibsen
    Apache Camel Committer

    Author of Camel in Action: http://www.manning.com/ibsen/
    Open Source Integration: http://fusesource.com
    Blog: http://davsclaus.blogspot.com/
    Twitter: http://twitter.com/davsclaus

Related Discussions

Discussion Navigation
viewthread | post
Discussion Overview
groupusers @
categoriescamel
postedNov 11, '09 at 4:59p
activeNov 11, '09 at 6:10p
posts2
users2
websitecamel.apache.org

2 users in discussion

Dragisa Krsmanovic: 1 post Claus Ibsen: 1 post

People

Translate

site design / logo © 2022 Grokbase