org.apache.camel.processor
Class Resequencer
java.lang.Object
org.apache.camel.impl.ServiceSupport
org.apache.camel.processor.Resequencer
- All Implemented Interfaces:
- Runnable, Service
public class Resequencer
- extends ServiceSupport
- implements Runnable
An implementation of the Resequencer
- Version:
- $Revision: 1.1 $
Resequencer
public Resequencer(Endpoint endpoint,
Processor processor,
Expression<Exchange> expression)
Resequencer
public Resequencer(Endpoint endpoint,
Processor processor,
List<Expression<Exchange>> expressions)
Resequencer
public Resequencer(Endpoint endpoint,
Processor processor,
Set<Exchange> set)
toString
public String toString()
- Overrides:
toString in class Object
run
public void run()
- Specified by:
run in interface Runnable
getExceptionHandler
public ExceptionHandler getExceptionHandler()
setExceptionHandler
public void setExceptionHandler(ExceptionHandler exceptionHandler)
getBatchSize
public int getBatchSize()
setBatchSize
public void setBatchSize(int batchSize)
getBatchTimeout
public long getBatchTimeout()
setBatchTimeout
public void setBatchTimeout(long batchTimeout)
processBatch
protected void processBatch()
throws Exception
- A transactional method to process a batch of messages up to a timeout period
or number of messages reached.
- Throws:
Exception
doStart
protected void doStart()
throws Exception
- Specified by:
doStart in class ServiceSupport
- Throws:
Exception
doStop
protected void doStop()
throws Exception
- Specified by:
doStop in class ServiceSupport
- Throws:
Exception
createSet
protected static Set<Exchange> createSet(Expression<Exchange> expression)
createSet
protected static Set<Exchange> createSet(List<Expression<Exchange>> expressions)
createSet
protected static Set<Exchange> createSet(Comparator<? super Exchange> comparator)
Copyright © 2007 Apache Software Foundation. All Rights Reserved.