Announcement Announcement Module
Collapse
No announcement yet.
Aggregator and threading model Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • Aggregator and threading model

    I have a splitter whose output channel is backed by a task executor. The tasks that process split messages are posted to a channel that's being processed by an aggregator. Aggregator then sends aggregated message out on a normal channel with no task executor.

    My question is does aggregator run its own thread or is it (randomly) one of the threads on which input messages are coming and when the release strategy approves the release?

    Thanks Rags

  • #2
    The aggregator is an entirely passive element.

    It's not random. When a message arrives at the aggregator, if the release strategy allows group release when a particular message arrives, the group is released on that thread.

    Comment


    • #3
      Gary, appreciate the quick response.

      By random, I meant in the setup I described, given the presence of a task executor in an earlier channel, the thread that will end up releasing the message can be any thread (randomly) in this task executor pool.

      Thanks Rags

      Comment


      • #4
        Yes, but it will always be the thread that is processing the message that permits the release.

        Comment

        Working...
        X