public class Resequencer extends BatchProcessor implements Traceable
DEFAULT_BATCH_SIZE, DEFAULT_BATCH_TIMEOUTshutdown, shuttingdown, started, starting, stopped, stopping, suspended, suspending| Constructor and Description |
|---|
Resequencer(CamelContext camelContext,
Processor processor,
Expression expression) |
Resequencer(CamelContext camelContext,
Processor processor,
Expression expression,
boolean allowDuplicates,
boolean reverse) |
Resequencer(CamelContext camelContext,
Processor processor,
Set<Exchange> collection,
Expression expression) |
| Modifier and Type | Method and Description |
|---|---|
protected static Set<Exchange> |
createSet(Comparator<? super Exchange> comparator,
boolean allowDuplicates,
boolean reverse) |
protected static Set<Exchange> |
createSet(Expression expression,
boolean allowDuplicates,
boolean reverse) |
String |
getTraceLabel()
Gets the trace label used for logging when tracing is enabled.
|
String |
toString() |
doStart, doStop, getBatchSize, getBatchTimeout, getCompletionPredicate, getExceptionHandler, getExpression, getId, getOutBatchSize, getProcessor, hasNext, isAllowDuplicates, isBatchConsumer, isGroupExchanges, isIgnoreInvalidExchanges, isReverse, next, process, process, processExchange, setAllowDuplicates, setBatchConsumer, setBatchSize, setBatchTimeout, setCompletionPredicate, setExceptionHandler, setGroupExchanges, setId, setIgnoreInvalidExchanges, setOutBatchSize, setReversedoResume, doShutdown, doSuspend, getStatus, getVersion, isRunAllowed, isStarted, isStarting, isStopped, isStopping, isStoppingOrStopped, isSuspended, isSuspending, isSuspendingOrSuspended, resume, shutdown, start, stop, suspendpublic Resequencer(CamelContext camelContext, Processor processor, Expression expression)
public Resequencer(CamelContext camelContext, Processor processor, Expression expression, boolean allowDuplicates, boolean reverse)
public Resequencer(CamelContext camelContext, Processor processor, Set<Exchange> collection, Expression expression)
public String toString()
toString in class BatchProcessorpublic String getTraceLabel()
TraceablegetTraceLabel in interface Traceableprotected static Set<Exchange> createSet(Expression expression, boolean allowDuplicates, boolean reverse)
protected static Set<Exchange> createSet(Comparator<? super Exchange> comparator, boolean allowDuplicates, boolean reverse)
Apache Camel