org.apache.camel.processor
Class Resequencer

java.lang.Object
  extended by org.apache.camel.impl.ServiceSupport
      extended by org.apache.camel.processor.BatchProcessor
          extended by org.apache.camel.processor.Resequencer
All Implemented Interfaces:
Processor, Service

public class Resequencer
extends BatchProcessor

An implementation of the Resequencer which can reorder messages within a batch.

Version:
$Revision: 1948 $

Field Summary
 
Fields inherited from class org.apache.camel.processor.BatchProcessor
DEFAULT_BATCH_SIZE, DEFAULT_BATCH_TIMEOUT
 
Constructor Summary
Resequencer(Processor processor, Expression expression)
           
Resequencer(Processor processor, List<Expression> expressions)
           
Resequencer(Processor processor, Set<Exchange> collection)
           
 
Method Summary
protected static Set<Exchange> createSet(Comparator<? super Exchange> comparator)
           
protected static Set<Exchange> createSet(Expression<Exchange> expression)
           
protected static Set<Exchange> createSet(List<Expression> expressions)
           
 String toString()
           
 
Methods inherited from class org.apache.camel.processor.BatchProcessor
doStart, doStop, getBatchSize, getBatchTimeout, getCollection, getExceptionHandler, getOutBatchSize, getProcessor, isInBatchCompleted, isOutBatchCompleted, process, processExchange, setBatchSize, setBatchTimeout, setExceptionHandler, setOutBatchSize
 
Methods inherited from class org.apache.camel.impl.ServiceSupport
addChildService, getThreadName, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, nextThreadCounter, removeChildService, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

Resequencer

public Resequencer(Processor processor,
                   Expression expression)

Resequencer

public Resequencer(Processor processor,
                   List<Expression> expressions)

Resequencer

public Resequencer(Processor processor,
                   Set<Exchange> collection)
Method Detail

toString

public String toString()
Overrides:
toString in class BatchProcessor

createSet

protected static Set<Exchange> createSet(Expression<Exchange> expression)

createSet

protected static Set<Exchange> createSet(List<Expression> expressions)

createSet

protected static Set<Exchange> createSet(Comparator<? super Exchange> comparator)


Copyright © 2009 IONA Open Source Community. All Rights Reserved.