[
https://issues.apache.org/jira/browse/SYNAPSE-1049?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Vanjikumaran Sivajothy updated SYNAPSE-1049:
--------------------------------------------
Attachment: SYNAPSE-1049.diff
Sample 702 Modified to demonstrate the improved functionality.
{Code}
<definitions xmlns="http://ws.apache.org/ns/synapse";>
<endpoint name="StockQuoteServiceEp">
<address uri="http://localhost:9000/services/SimpleStockQuoteService";>
<suspendOnFailure>
<errorCodes>-1</errorCodes>
<progressionFactor>1.0</progressionFactor>
</suspendOnFailure>
</address>
</endpoint>
<sequence name="fault">
<log level="full">
<property name="MESSAGE" value="Executing default 'fault'
sequence"/>
<property name="ERROR_CODE"
expression="get-property('ERROR_CODE')"/>
<property name="ERROR_MESSAGE"
expression="get-property('ERROR_MESSAGE')"/>
</log>
<drop/>
</sequence>
<sequence name="main">
<in>
<log level="full"/>
<property name="FORCE_SC_ACCEPTED" value="true" scope="axis2"/>
<property name="OUT_ONLY" value="true"/>
<property name="target.endpoint" value="StockQuoteServiceEp"/>
<store messageStore="MyStore"/>
</in>
<description>The main sequence for the message mediation</description>
</sequence>
<messageStore name="MyStore"/>
<messageProcessor
class="org.apache.synapse.message.processors.forward.ScheduledMessageForwardingProcessor"
name="ScheduledProcessor" messageStore="MyStore">
<parameter name="interval">10000</parameter>
<parameter name="max.deliver.attempts">2</parameter>
<parameter name="max.deliver.drop">true</parameter>
</messageProcessor>
</definitions>
{code}
*Client*
{code}
ant stockquote -Daddurl=http://localhost:9000/services/SimpleStockQuoteService
-Dtrpurl=http://localhost:8280/ -Dmode=placeorder
{code}
> Drop the message from store after Max deliver attempt
> -----------------------------------------------------
>
> Key: SYNAPSE-1049
> URL: https://issues.apache.org/jira/browse/SYNAPSE-1049
> Project: Synapse
> Issue Type: Improvement
> Reporter: Vanjikumaran Sivajothy
> Assignee: Hiranya Jayathilaka
> Attachments: SYNAPSE-1049.diff
>
>
> In message forwarding processor with message store use-case, the message
> processor will get deactivated after max delivery attempts and rest of the
> message will pilled up in the queue due to BE failure or invalid message
> format.
> If message forwarding processor has the flexibility to drop the message when
> user explicitly mention to drop the message after max delivery attempt, It is
> possible to prevent the Queue pill up in Message Store.
> To solve this, Introduce new parameter in ForwardingJob and drop the message
> based on the condition where it should have max delivery + drop enabled.
> *Example*
> {code}
> <messageProcessor
> class="org.apache.synapse.message.processors.forward.ScheduledMessageForwardingProcessor"
> name="ScheduledProcessor" messageStore="MyStore">
> <parameter name="interval">10000</parameter>
> <parameter name="max.deliver.attempts">2</parameter>
> <parameter name="max.deliver.drop">true</parameter>
> </messageProcessor>
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
