Announcement Announcement Module
No announcement yet.
Pluggable/Persistent Store for Aggregation? Page Title Module
Move Remove Collapse
Conversation Detail Module
  • Filter
  • Time
  • Show
Clear All
new posts

  • Pluggable/Persistent Store for Aggregation?

    We have a requirement to aggregate messages that arrive independently and we must be able to recover incomplete sets in the case of process failure.

    I think some sort of Aggregator/BarrierHandler combo would do the trick but we need a persistent store for the Barriers (and some way of loading them on restart I guess). Is this something that is available or planned for a later release? I've seen INT-330 which seems to address this but gives distributed processing environment as the driver rather than recoverability - would this also address my problem?

  • #2

    We will provide support for persistent store in an upcoming version, so stay tuned. We'll update the roadmap accordingly.