Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagehtml/xml
            <!-- 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:

...