...
Code Block | ||
---|---|---|
| ||
<!-- Introduction to Scheduled Message Forwarding Processor --> <?xml version="1.0" encoding="UTF-8"?> <definitions xmlns="http://ws.apache.org/ns/synapse"> <taskManager provider="org.wso2.carbon.mediation.ntask.NTaskTaskManager"/> <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')" name="ERROR_CODE"/> <property name="ERROR_MESSAGE" expression="get-property('ERROR_MESSAGE')" name="ERROR_MESSAGE"/> </log> <drop/> </sequence> <sequence name="main"> <in> <log level="full"/> <property name="FORCE_SC_ACCEPTED" valuescope="trueaxis2" scopevalue="axis2true"/> <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.processor.processorsimpl.forwardforwarder.ScheduledMessageForwardingProcessor" messageStore="MyStore" name="ScheduledProcessor" messageStoretargetEndpoint="MyStoreStockQuoteServiceEp"> <parameter name="interval">10000</parameter> <parameter name="throttle">false</parameter> </messageProcessor> <parameter name="target.endpoint">StockQuoteServiceEp</parameter> </messageProcessor> </definitions> |
Prerequisites:
...