You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by "Buddhima Wijeweera (JIRA)" <ji...@apache.org> on 2012/07/14 10:05:33 UTC
[jira] [Created] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Buddhima Wijeweera created SYNAPSE-893:
------------------------------------------
Summary: 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
Adding Resequencer Message Processor for Synapse.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
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-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Attachment: Resequencer_Patch.patch
Currently resequencer has come up with more modifications compared to previous version.
1. Included docs related to coding
2. Modified parameter names to give more clear idea
3. Added 2 new optional parameters to help in deciding starting sequence number.
requiredInitMessages - to decide how many messages Resequencer should wait before deciding the starting sequence number. Default value is 4.
requiredInitMessagesDelay - time that resequencer should wait until requiredInitMessages comes. Default value is 5.
4. Modification to Message Processor Serializer and Factory in order to recognize parameters with name and expressions.
5. Improving test case for Message Processor Serialization to test the improvement in (4).
I have already tested the functionality of this resequencer along with the In-memory store and a persistent store.
Thanks for the comments about the previous versions and would like to know your opinions on this improvement too.
> 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.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: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
[jira] [Updated] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Attachment: (was: Resequencer_Patch.patch)
> 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
>
> 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: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
[jira] [Updated] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Attachment: (was: Resequencer-Docs.zip)
> 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
>
> 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="MyStore">
> <parameter name="interval">15000</parameter>
> <parameter name="seqNo" xmlns:bank="http://bank.resequence.synapse.org" expression="//bank:display/bank:seqNo"/>
> <parameter name="sequence">next_seq</parameter>
>
> </messageProcessor>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
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-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Description:
Adding Resequencer Message Processor for Synapse.
Configuration is as follows:
<messageProcessor
class="org.apache.synapse.message.processors.resequence.ResequencingProcessor"
name="ResequencingProcessor" messageStore="MyStore">
<parameter name="interval">15000</parameter>
<parameter name="seqNo" xmlns:bank="http://bank.resequence.synapse.org" expression="//bank:display/bank:seqNo"/>
<parameter name="sequence">next_seq</parameter>
</messageProcessor>
was:Adding Resequencer Message Processor for Synapse.
> 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
>
> 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="MyStore">
> <parameter name="interval">15000</parameter>
> <parameter name="seqNo" xmlns:bank="http://bank.resequence.synapse.org" expression="//bank:display/bank:seqNo"/>
> <parameter name="sequence">next_seq</parameter>
>
> </messageProcessor>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
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-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Description:
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>
was:
Adding Resequencer Message Processor for Synapse.
Configuration is as follows:
<messageProcessor
class="org.apache.synapse.message.processors.resequence.ResequencingProcessor"
name="ResequencingProcessor" messageStore="MyStore">
<parameter name="interval">15000</parameter>
<parameter name="seqNo" xmlns:bank="http://bank.resequence.synapse.org" expression="//bank:display/bank:seqNo"/>
<parameter name="sequence">next_seq</parameter>
</messageProcessor>
> 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
>
> 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: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
[jira] [Commented] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Andreas Veithen (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13415543#comment-13415543 ]
Andreas Veithen commented on SYNAPSE-893:
-----------------------------------------
Unit tests?
Documentation?
> 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
>
> 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="MyStore">
> <parameter name="interval">15000</parameter>
> <parameter name="seqNo" xmlns:bank="http://bank.resequence.synapse.org" expression="//bank:display/bank:seqNo"/>
> <parameter name="sequence">next_seq</parameter>
>
> </messageProcessor>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
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] [Commented] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13470961#comment-13470961 ]
Buddhima Wijeweera commented on SYNAPSE-893:
--------------------------------------------
Hi Charith,
Thanks for inspecting Resequencing Processor code.
I made a change to exception handing part of findFirstSeqNum() in Resequencing Processor. Now it expects NumberFormatException if the number pointing by Xpath is not an integer, and Exception that could happen due to non-existence of message store or any other reason. All Exceptions are handled by handleException() method in the class, so Exceptions are logged through it.
> 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: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
[jira] [Updated] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Attachment: (was: resequencer.patch)
> 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
> 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: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
[jira] [Updated] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Attachment: Resequencer-Docs.zip
Docs for Resequencing Processor
> 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-Docs.zip, 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="MyStore">
> <parameter name="interval">15000</parameter>
> <parameter name="seqNo" xmlns:bank="http://bank.resequence.synapse.org" expression="//bank:display/bank:seqNo"/>
> <parameter name="sequence">next_seq</parameter>
>
> </messageProcessor>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
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-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Attachment: resequencer.patch
Resequencing message processor
> 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
>
> Original Estimate: 672h
> Remaining Estimate: 672h
>
> Adding Resequencer Message Processor for Synapse.
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
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] [Commented] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ 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: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
[jira] [Updated] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Attachment: Resequencer.patch
Added new parameter to determine whether to delete messages contain sequence number less than required
> 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: patch.txt, Resequencer.patch, 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: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
[jira] [Updated] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Attachment: Resequencer.patch
Reorganized findFirstSeqNum() method in ResequencingProcessor.java
Avoid executing multiple job instances while finding initial sequence number.
> 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: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
[jira] [Commented] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Charith Dhanushka Wickramarachchi (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13470630#comment-13470630 ]
Charith Dhanushka Wickramarachchi commented on SYNAPSE-893:
-----------------------------------------------------------
Can you explain the design of the Re-sequencing processor In this JIRA. And Also Can you explain logic behind the method
findFirstSeqNum() , in ResequencingProcessor.java I can see You have Ignored exception and NullPointer exception in that method. Can you explain in what scenarios You are expecting this exceptions? and I think Its not a good idea to ignore the Exceptions even without a warning log in this scenario.
--Charith
> 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
>
> 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: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
[jira] [Updated] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Attachment: Resequencer.patch
Fixed issue with casting and resolving problems caused due to multiple instances at startup
> 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.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: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
[jira] [Updated] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Attachment: patch.txt
Patch file created using "svn diff" attached.
> 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: patch.txt, 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: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
[jira] [Commented] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Charith Dhanushka Wickramarachchi (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13417987#comment-13417987 ]
Charith Dhanushka Wickramarachchi commented on SYNAPSE-893:
-----------------------------------------------------------
Hi Buddhima ,
As Andreas pointed out. To get this patch in to the trunk we need to have unit tests cases and java docs and later we will need sample documentation too. I can see places in you diff which deviate from the synapse coding style. and it also have some IDE generated comments. You need to rectify them too and update the patch.
Refer to [1][2] for more details.
[1]http://synapse.apache.org/dev/developer-guide.html
[2]http://synapse.apache.org/dev/best-practices.html
--Charith
> 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-Docs.zip, 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="MyStore">
> <parameter name="interval">15000</parameter>
> <parameter name="seqNo" xmlns:bank="http://bank.resequence.synapse.org" expression="//bank:display/bank:seqNo"/>
> <parameter name="sequence">next_seq</parameter>
>
> </messageProcessor>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
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-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Buddhima Wijeweera updated SYNAPSE-893:
---------------------------------------
Description:
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>
<parameter name="deleteDuplicateMessages">true</parameter>
</messageProcessor>
was:
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>
> 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: patch.txt, Resequencer.patch, 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>
> <parameter name="deleteDuplicateMessages">true</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: dev-unsubscribe@synapse.apache.org
For additional commands, e-mail: dev-help@synapse.apache.org
[jira] [Commented] (SYNAPSE-893) Resequencing Message Processor For
Synapse
Posted by "Buddhima Wijeweera (JIRA)" <ji...@apache.org>.
[ https://issues.apache.org/jira/browse/SYNAPSE-893?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13415893#comment-13415893 ]
Buddhima Wijeweera commented on SYNAPSE-893:
--------------------------------------------
Hi Andreas Veithen,
Yes, I'll soon add those also. But before that I have to do some more modifications in MessageProcessorSerializer as I made some changes to MessageProcessorFactory. I would thankful to you if you can help with those.
> 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
>
> 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="MyStore">
> <parameter name="interval">15000</parameter>
> <parameter name="seqNo" xmlns:bank="http://bank.resequence.synapse.org" expression="//bank:display/bank:seqNo"/>
> <parameter name="sequence">next_seq</parameter>
>
> </messageProcessor>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
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