Announcement Announcement Module
Collapse
No announcement yet.
messages not getting aggregated for a msg group after release strategy returns true Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • messages not getting aggregated for a msg group after release strategy returns true

    Hi,



    We are trying to use aggregator for one of our usecases.
    The aggregator, correlator and the release strategy works perfectly until release strategy returns true for a message group.

    for a message group, can t we aggregate messages after release strategy has returned true ?

    The below is the configuration


    <si:aggregator id="aggregatorSIBean"
    input-channel="MAIN_CHANNEL"
    output-channel="AFTER_AGGREGATOR_CHANNEL"
    ref="aggregator"
    method="aggregate"
    release-strategy="release"
    send-partial-result-on-expiry="false"
    correlation-strategy="correlation"
    correlation-strategy-method="correlate"
    send-timeout="86420000" />

    <!-- release-strategy-method="release" -->

    <bean id="aggregator" class="com.pg.SI.Aggregator"/>
    <bean id="release" class="com.pg.SI.Release"/>
    <bean id="correlation" class="com.pg.SI.Correlator"/>



    Thanks,
    D.Radhakrishnan

  • #2
    See

    Code:
    <xsd:attribute name="expire-groups-upon-completion" type="xsd:string">
    	<xsd:annotation>
    	        <xsd:documentation>
    			Boolean flag specifying if MessageGroup should be removed once completed. Useful for
    			handling late arrival use cases where messages arriving with the correlationKey that
    			is the same as the completed MessageGroup will be discarded. Default is 'false'
    		</xsd:documentation>
    	</xsd:annotation>
    </xsd:attribute>
    Setting it to true means a new group will start when a message with the same correlation arrives after a release.
    Last edited by Gary Russell; Mar 21st, 2013, 07:17 AM.

    Comment


    • #3
      Hi,


      after giving expire-groups-upon-completion=true, the messages were processed by the aggregator. Thanks


      aggreator config is

      <si:aggregator id="aggregatorSIBean"

      input-channel="MAIN_CHANNEL"

      output-channel="AFTER_AGGREGATOR_CHANNEL"

      ref="aggregator"

      method="aggregate"

      release-strategy="release"

      expire-groups-upon-completion="true"

      correlation-strategy="correlation"

      correlation-strategy-method="correlate"

      send-timeout="86420000" />

      Comment

      Working...
      X