Skip to content

Instantly share code, notes, and snippets.

Embed
What would you like to do?
mule_flows
<flow name="aws_testFlow">
<http:listener config-ref="HTTP_Listener_Configuration" path="/s3" doc:name="http_listener"/>
<sqs:send-message config-ref="Amazon_SQS__Configuration" doc:name="aws_sqs_publisher">
<sqs:message messageBody="#[payload]"/>
</sqs:send-message>
<set-payload value="Message published" doc:name="response_payload"/>
</flow>
<flow name="aws_testFlow1">
<sqs:receive-messages config-ref="Amazon_SQS__Configuration" doc:name="aws_sqs_receiver"/>
<set-variable variableName="fileName" value="test1/testfile_#[server.dateTime].txt" doc:name="set_fileName_variable"/>
<s3:create-object config-ref="Amazon_S3__Configuration" bucketName="${s3.bucketName}" key="#[flowVars.fileName]" doc:name="aws_s3"/>
<logger message="#['File ' + flowVars.fileName + ' written successful in S3']" level="INFO" doc:name="log_message"/>
</flow>
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
You can’t perform that action at this time.