Mule에서 커스텀 어 그리 게이터를 만드는 방법은?

Question

mule 3.x에서 완전히 맞춤형 어 그리 게이터를 생성하기위한 권장 방법은 무엇입니까? 완전히 사용자 정의, 나는 상관 ID를, 메시지 수, 등을 사용하지, 내 자신의 논리에 따라 의미

mulesoft 사이트의 문서 오래된, 3.X에 존재하지 않는 AbstractEventAggregator를 사용하여 말하고있다 :

http://www.mulesoft.org/docs/site/3.2.0/apidocs/org/mule/routing/AbstractAggregator.html

그러나, 아니이 있습니다 :이 클래스는 3.X에 AbstractAggregator로 이름이 바뀌 었습니다처럼 깊이 파고

http://www.mulesoft.org/documentation/display/MULE3USER/Message+Splitting+and+Aggregatio

, 그것은 보인다 이것을 사용하는 방법을 보여주는 예제. 위의 첫 번째 링크에서 설명한 LoanBroker 예제는 실제로 상관 어 그리 게이터를 사용합니다 (2.x 예에서는 문서가 참조하는 것으로 가정합니다).

한순간에 추상 메소드 shouldAggregate 및 doAggregate를 가진 추상 클래스가있었습니다. 이것은 내가 확장하고 싶은 종류의 수업입니다.

Answer 1

AbstractAggregator의 서브 클래 싱 예제는 아래 TestAggregator을 참조하십시오.

import org.mule.DefaultMuleEvent; 
import org.mule.DefaultMuleMessage; 
import org.mule.api.MuleContext; 
import org.mule.api.MuleEvent; 
import org.mule.api.store.ObjectStoreException; 
import org.mule.api.transformer.TransformerException; 
import org.mule.routing.AbstractAggregator; 
import org.mule.routing.AggregationException; 
import org.mule.routing.EventGroup; 
import org.mule.routing.correlation.CollectionCorrelatorCallback; 
import org.mule.routing.correlation.EventCorrelatorCallback; 
import org.mule.util.concurrent.ThreadNameHelper; 

import java.util.Iterator; 

public class TestAggregator extends AbstractAggregator 
{ 
    @Override 
    protected EventCorrelatorCallback getCorrelatorCallback(MuleContext muleContext) 
    { 
     return new CollectionCorrelatorCallback(muleContext,false,storePrefix) 
     { 
      @Override 
      public MuleEvent aggregateEvents(EventGroup events) throws AggregationException 
      { 
       StringBuffer buffer = new StringBuffer(128); 

       try 
       { 
        for (Iterator<MuleEvent> iterator = events.iterator(); iterator.hasNext();) 
        { 
         MuleEvent event = iterator.next(); 
         try 
         { 
          buffer.append(event.transformMessageToString()); 
         } 
         catch (TransformerException e) 
         { 
          throw new AggregationException(events, null, e); 
         } 
        } 
       } 
       catch (ObjectStoreException e) 
       { 
        throw new AggregationException(events,null,e); 
       } 

       logger.debug("event payload is: " + buffer.toString()); 
       return new DefaultMuleEvent(new DefaultMuleMessage(buffer.toString(), muleContext), events.getMessageCollectionEvent()); 
      } 
     }; 
    } 
}