You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by "Vijayaratha Vijayasingam (JIRA)" <ji...@apache.org> on 2011/08/02 07:43:27 UTC

[jira] [Created] (SYNAPSE-790) Aggregate message processor

Aggregate message processor
---------------------------

                 Key: SYNAPSE-790
                 URL: https://issues.apache.org/jira/browse/SYNAPSE-790
             Project: Synapse
          Issue Type: New Feature
          Components: Core
    Affects Versions: NIGHTLY
            Reporter: Vijayaratha Vijayasingam
             Fix For: NIGHTLY


 Aggregate processor may give a control to user to process messages,which are stored in a message store,  based on a correlation pattern.
To use the aggregate processor, user should write a custom correlation class and  should return back the correlated messages to the processor..

For this , there are two required parameters are defined;
  <parameter name="sequence">send_seq</parameter>
  <parameter name="correlation.class">org.apache.synapse.message.processors.aggregate.TestCorrelation</parameter>

So, the aggregate processor configuration would be;

   <messageProcessor class="org.apache.synapse.message.processors.aggregate.AggregateMessageProcessor" name="aggregateMsgPorcessor" messageStore="testMsgStore">
        <parameter name="interval">20000</parameter>
        <parameter name="sequence">send_seq</parameter>
        <parameter name="correlation.class">org.apache.synapse.message.processors.aggregate.TestCorrelation</parameter>
    </messageProcessor>

Messages will be processed based on the defined sequence(eg: send_seq)

This does not provide  guaranteed delivery, since ' Forwarding processor' which provides that functionality..If user needs guaranteed delivery then he can define another 'Forwarding processor within the "sequence"..


--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org

[jira] [Updated] (SYNAPSE-790) Aggregate message processor

Posted by "Vijayaratha Vijayasingam (JIRA)" <ji...@apache.org>.
     [ https://issues.apache.org/jira/browse/SYNAPSE-790?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Vijayaratha Vijayasingam updated SYNAPSE-790:
---------------------------------------------

    Attachment: AggregateMessageProcessor.patch

I have attached initial implementation for this..
Please review and commit...

> Aggregate message processor
> ---------------------------
>
>                 Key: SYNAPSE-790
>                 URL: https://issues.apache.org/jira/browse/SYNAPSE-790
>             Project: Synapse
>          Issue Type: New Feature
>          Components: Core
>    Affects Versions: NIGHTLY
>            Reporter: Vijayaratha Vijayasingam
>             Fix For: NIGHTLY
>
>         Attachments: AggregateMessageProcessor.patch
>
>
>  Aggregate processor may give a control to user to process messages,which are stored in a message store,  based on a correlation pattern.
> To use the aggregate processor, user should write a custom correlation class and  should return back the correlated messages to the processor..
> For this , there are two required parameters are defined;
>   <parameter name="sequence">send_seq</parameter>
>   <parameter name="correlation.class">org.apache.synapse.message.processors.aggregate.TestCorrelation</parameter>
> So, the aggregate processor configuration would be;
>    <messageProcessor class="org.apache.synapse.message.processors.aggregate.AggregateMessageProcessor" name="aggregateMsgPorcessor" messageStore="testMsgStore">
>         <parameter name="interval">20000</parameter>
>         <parameter name="sequence">send_seq</parameter>
>         <parameter name="correlation.class">org.apache.synapse.message.processors.aggregate.TestCorrelation</parameter>
>     </messageProcessor>
> Messages will be processed based on the defined sequence(eg: send_seq)
> This does not provide  guaranteed delivery, since ' Forwarding processor' which provides that functionality..If user needs guaranteed delivery then he can define another 'Forwarding processor within the "sequence"..

--
This message is automatically generated by JIRA.
For more information on JIRA, see: http://www.atlassian.com/software/jira

        

---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org