Aggregator Producer

Table of Contents

    Aggregator Producer

    The Aggregator Producer is used for combining several different messages into one message. This producer uses a number of pluggable functionalities for this.

    The functionalities determine how the aggregator producer decides to make a composite message, how to determine which incoming messages belong together and where incoming messages are temporarily stored.

    In the table below, you will find an explanation about these properties. All attributes with a ‘*’ are mandatory.




    By default, we fill this out with the technical ‘tag’, followed by a serial number. Changing the name is optional.


    Check this box if you want this service to be enabled.

    Output Flow*

    Reference to a flow were the complete aggregated message is send to after aggregation

    Discard Flow

    Reference to a flow were an incomplete message is send to after a time-out.

    Correlation Property

    When no correlation-strategy is set a different correlation property than the default correlationId can be set.


    Time-out in milli seconds for the incomplete messages to be send to discard flow. If 0 (default) no timeout is used. Incomplete messages will reside till restart.


    Name of the MessagePart in a ConnectMessage where the content of the file is being stored.

    Advanced properties

    In the next list you will find the Advanced options

    Attribute Description
    Aggregator Reference

    Reference to an aggregator bean. The bean must be an extension of the AbstractMyESBAggregator. When not set    the default MyESBAggregator is used. This implementation will add all found messages in group as separate            messageparts to a ConnectMessage. The part id's will be msgprt[idx]. The type of the part will be according to          the message type. Headers of individual messages will be set on ConnectMessagePart. A composition of all headers    will be set on the ConnectMessage.

    MessageStore Name of the MessagePart in a ConnectMessage where the content of the file is being stored.
    Correlation Strategy

    Reference to a correlation strategy bean. The bean must be an extension of the AbstractMyESBCorrelationStrategy. When not set a default MyESBPropertyCorrelationStrategy is used with default correlation-property correlationId

    Release Strategy

    Reference to a release strategy bean. The bean must be an extension of the AbstractMyESBReleaseStrategy. When not seta default SequenceSizeReleaseStrategy is used.

    This implementation consults the sequenceNumber and sequenceSize propertiesof each arriving message to decide when a message group is complete and ready to be aggregated

    Header properties

    If you want to use the aggregator the following properties must be available in de header of the message.

    Properties value
    CorrelationId Unique ID that connects the messages / files with each other
    SequenceNumber Place in the sequence
    SequenceSize Total sequence size


    Copyright © 2019 ConnectPlaza.   For pricing, account management and more go to https://www.connectplaza.com

    About Connectplaza

    Si components version:   

    Lorem ipsum delore set

    Lorem ipsum delore set

    Window size is not optimal. Please enlarge for optimal experience

    No connection

    No response from the server. This window will automaticly disappear by an valid connection