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: [email protected]
For additional commands, e-mail: [email protected]
