logArchiver.xml

<flow name="logArchiverFlow">
    <poll doc:name="Poll">
        <fixed-frequency-scheduler frequency="${polling.frequency.hours}" timeUnit="HOURS"/>
        <set-payload value="#['${log.achiver.config}']" mimeType="application/json" doc:name="Read config"/>
    </poll>
    <json:json-to-object-transformer returnClass="java.util.HashMap" doc:name="JSON to Object"/>
    <set-variable variableName="configCollection" value="#[payload.config]" doc:name="Set configCollection flowVar"/>
    <foreach collection="#[flowVars.configCollection]" counterVariableName="configCounter" doc:name="For Each item in Config">
        <set-variable variableName="config" value="#[flowVars.configCollection[configCounter-1]]" doc:name="Set config flowVar"/>
        <logger message="#['Archiving log files for CloudHub application: &quot;' + flowVars.config.anypointApplication + '&quot; to Amazon S3 bucket: &quot;' + flowVars.config.amazonS3Bucket + '&quot;...']" level="INFO" doc:name="Logger"/>
        <flow-ref name="archiveLogFile" doc:name="archiveLogFile"/>
    </foreach>
    <catch-exception-strategy doc:name="Catch Exception Strategy">
        <logger level="ERROR" doc:name="Logger"/>
    </catch-exception-strategy>
</flow>