Parallel Processing in Mule 3

vm-queue.xml

<flow name="example_splitterFlow">
	<inbound-endpoint exchange-pattern="one-way" host="localhost" port="8081" doc:name="HTTP" />
	<set-payload value="#[['1','2','3','4']]" doc:name="Set Payload" />
	<collection-splitter doc:name="Collection Splitter" />
	<outbound-endpoint exchange-pattern="one-way" path="test" doc:name="VM" />
</flow>
<flow name="example_splitterFlow1">
	<inbound-endpoint exchange-pattern="one-way" path="test" doc:name="VM" />
	<logger message="START #[payload]" level="INFO" doc:name="Logger" />
	<logger message="#[Thread.sleep(5000)]" level="INFO" doc:name="Logger" />
	<logger message="END #[payload]" level="INFO" doc:name="Logger" />
	<outbound-endpoint exchange-pattern="one-way" path="test2" doc:name="VM" />
</flow>
<flow name="example_splitterFlow2">
	<inbound-endpoint exchange-pattern="one-way" path="test2" doc:name="VM" />
	<collection-aggregator failOnTimeout="true" doc:name="Collection Aggregator" />
	<logger message="FINISH" level="INFO" doc:name="Logger" />
</flow>