MULE开发实例1---并行调用多个webservice接口

package org.my; import org.mule.DefaultMuleEvent; import org.mule.api.MuleEvent; import org.mule.api.MuleException; import org.mule.api.MuleMessage; import org.mule.api.routing.AggregationContext; import org.mule.routing.AggregationStrategy; public class CustomAggregationStrategy implements AggregationStrategy { @Override public MuleEvent aggregate(AggregationContext context) throws MuleException { // TODO Auto-generated method stub MuleEvent result = null; int count = 0; /* MuleMessage message = null; message.set result.setMessage(message); */ String str = ""; for (MuleEvent event : context.collectEventsWithoutExceptions()) { try { str += event.getMessage().getPayloadAsString(); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } result = DefaultMuleEvent.copy(context.collectEventsWithoutExceptions().get(0)); result.getMessage().setPayload(str); return result; } }