[
https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13470965#comment-13470965
]
Buddhima Wijeweera commented on SYNAPSE-893:
--------------------------------------------
Hi all,
Let me explain the design of Resequencing Processor.
Resequencing Processor is a message processor which can send messages in an
order. Basically it scans the messages in a given message store, picks up the
message that should be send next and handover the message to the sequence
mentioned as "nextEsbSequence" in parameter list. To do that Resequencing
processor uses a sequence number reside inside messages which is specified by
"seqNumXpath". Resequencing processor do continuous scanning message store
after interval specified by "interval".
Selecting starting sequence is done automatically and can be described as
follows:
1. At the start-up resequencing processor looks message store and if any
message found select starting sequence number from those.
2. If resequencing processor fails to select starting sequence number at
start-up, it waits until "requiredInitMessages" messages arrive with number of
checks given by "requiredInitMessagesDelay" ("requiredInitMessages" and
"requiredInitMessagesDelay" have default values 4,5 respectively) and select
starting sequence number
3. If resequencing processor still fails, it will select starting sequence
number from messages already in store or from the first message it receives.
Currently Resequencing processor capable of working with in-memory message
store, but can use with persistent message stores too. With this improvement
Synapse will be able to exhibit Resequencer EAI pattern.
Thanks
> Resequencing Message Processor For Synapse
> ------------------------------------------
>
> Key: SYNAPSE-893
> URL: https://issues.apache.org/jira/browse/SYNAPSE-893
> Project: Synapse
> Issue Type: New Feature
> Reporter: Buddhima Wijeweera
> Labels: patch
> Attachments: Resequencer.patch, Resequencer.patch
>
> Original Estimate: 672h
> Remaining Estimate: 672h
>
> Adding Resequencer Message Processor for Synapse.
> Configuration is as follows:
> <messageProcessor
>
> class="org.apache.synapse.message.processors.resequence.ResequencingProcessor"
>
> name="ResequencingProcessor" messageStore="MyQueue">
> <parameter name="interval">10000</parameter>
> <parameter name="seqNumXpath" xmlns:bank="http://bank.resequence.synapse.org";
> expression="//bank:display/bank:seqNo"/>
> <parameter name="nextEsbSequence">next_seq</parameter>
> <parameter name="requiredInitMessages">15</parameter>
> <parameter name="requiredInitMessagesDelay">2</parameter>
> </messageProcessor>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
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]
