org.apache.camel.model
Class ResequencerType

java.lang.Object
  extended by org.apache.camel.model.OptionalIdentifiedType<Type>
      extended by org.apache.camel.model.ProcessorType<ProcessorType>
          extended by org.apache.camel.model.ResequencerType
All Implemented Interfaces:
Block

public class ResequencerType
extends ProcessorType<ProcessorType>

Represents an XML <resequencer/> element

Version:
$Revision: 1948 $

Field Summary
 
Fields inherited from class org.apache.camel.model.ProcessorType
DEFAULT_TRACE_CATEGORY
 
Fields inherited from class org.apache.camel.model.OptionalIdentifiedType
nodeCounters
 
Constructor Summary
ResequencerType()
           
ResequencerType(List<Expression> expressions)
           
 
Method Summary
 ResequencerType batch()
          Configures the batch-based resequencing algorithm using the default configuration.
 ResequencerType batch(BatchResequencerConfig config)
          Configures the batch-based resequencing algorithm using the given BatchResequencerConfig.
 ResequencerType capacity(int capacity)
           
 ResequencerType comparator(ExpressionResultComparator<Exchange> comparator)
           
protected  Resequencer createBatchResequencer(RouteContext routeContext, BatchResequencerConfig config)
          Creates a batch Resequencer instance applying the given config.
 Processor createProcessor(RouteContext routeContext)
           
protected  StreamResequencer createStreamResequencer(RouteContext routeContext, StreamResequencerConfig config)
          Creates a StreamResequencer instance applying the given config.
 ResequencerType expression(ExpressionType expression)
           
 BatchResequencerConfig getBatchConfig()
           
 BatchResequencerConfig getBatchConfig(BatchResequencerConfig defaultConfig)
           
 List<ExpressionType> getExpressions()
           
 String getLabel()
          Returns a label to describe this node such as the expression if some kind of expression node
 List<ProcessorType<?>> getOutputs()
           
 String getShortName()
          Returns a short name for this node which can be useful for ID generation or referring to related resources like images
 StreamResequencerConfig getStreamConfig()
           
 void setBatchConfig(BatchResequencerConfig batchConfig)
           
 void setOutputs(List<ProcessorType<?>> outputs)
           
 void setStreamConfig(StreamResequencerConfig streamConfig)
           
 ResequencerType size(int batchSize)
           
 ResequencerType stream()
          Configures the stream-based resequencing algorithm using the default configuration.
 ResequencerType stream(StreamResequencerConfig config)
          Configures the stream-based resequencing algorithm using the given StreamResequencerConfig.
 ResequencerType timeout(long timeout)
           
 String toString()
           
 
Methods inherited from class org.apache.camel.model.ProcessorType
addInterceptor, addInterceptor, addOutput, addRoutes, aggregator, aggregator, aggregator, aggregator, aggregator, bean, bean, bean, bean, beanRef, beanRef, choice, clearOutput, configureChild, convertBodyTo, convertBodyTo, convertFaultBodyTo, convertOutBodyTo, createCompositeProcessor, createErrorHandlerBuilder, createOutputsProcessor, createOutputsProcessor, delayer, delayer, delayer, delayer, end, errorHandler, exception, filter, filter, filter, filter, getErrorHandlerBuilder, getErrorHandlerRef, getInheritErrorHandlerFlag, getNodeFactory, getParent, handleFault, idempotentConsumer, idempotentConsumer, inheritErrorHandler, inOnly, inOnly, inOnly, inOnly, inOnly, inOnly, inOut, inOut, inOut, inOut, inOut, inOut, intercept, intercept, intercept, intercept, interceptor, interceptors, isInheritErrorHandler, isInheritErrorHandler, loadBalance, loop, loop, loop, makeProcessor, marshal, marshal, marshal, marshal, multicast, multicast, multicast, onException, pipeline, pipeline, pipeline, policies, policy, popBlock, proceed, process, processRef, pushBlock, recipientList, recipientList, removeFaultHeader, removeHeader, removeProperty, resequencer, resequencer, resequencer, resequencer, routingSlip, routingSlip, routingSlip, setBody, setBody, setErrorHandlerBuilder, setErrorHandlerBuilderIfNull, setErrorHandlerRef, setExchangePattern, setFaultBody, setFaultHeader, setHeader, setHeader, setHeader, setInheritErrorHandlerFlag, setNodeFactory, setOutBody, setOutBody, setOutHeader, setOutHeader, setParent, setProperty, setProperty, splitter, splitter, splitter, splitter, splitter, splitter, splitter, splitter, splitter, splitter, splitter, splitter, stop, thread, thread, throttler, throwFault, throwFault, to, to, to, to, to, to, to, to, to, to, trace, trace, transform, transform, tryBlock, unmarshal, unmarshal, unmarshal, unmarshal, wrapInErrorHandler, wrapProcessor, wrapProcessorInInterceptors
 
Methods inherited from class org.apache.camel.model.OptionalIdentifiedType
createId, describe, description, description, getDescription, getId, getNodeCounter, id, idOrCreate, setDescription, setId
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ResequencerType

public ResequencerType()

ResequencerType

public ResequencerType(List<Expression> expressions)
Method Detail

getShortName

public String getShortName()
Description copied from class: OptionalIdentifiedType
Returns a short name for this node which can be useful for ID generation or referring to related resources like images

Overrides:
getShortName in class OptionalIdentifiedType<ProcessorType>
Returns:
defaults to "node" but derived nodes should overload this to provide a unique name

stream

public ResequencerType stream()
Configures the stream-based resequencing algorithm using the default configuration.

Returns:
this instance.

batch

public ResequencerType batch()
Configures the batch-based resequencing algorithm using the default configuration.

Returns:
this instance.

stream

public ResequencerType stream(StreamResequencerConfig config)
Configures the stream-based resequencing algorithm using the given StreamResequencerConfig.

Returns:
this instance.

batch

public ResequencerType batch(BatchResequencerConfig config)
Configures the batch-based resequencing algorithm using the given BatchResequencerConfig.

Returns:
this instance.

expression

public ResequencerType expression(ExpressionType expression)

toString

public String toString()
Overrides:
toString in class Object

getLabel

public String getLabel()
Description copied from class: ProcessorType
Returns a label to describe this node such as the expression if some kind of expression node

Overrides:
getLabel in class ProcessorType<ProcessorType>

getExpressions

public List<ExpressionType> getExpressions()

getOutputs

public List<ProcessorType<?>> getOutputs()
Specified by:
getOutputs in class ProcessorType<ProcessorType>

setOutputs

public void setOutputs(List<ProcessorType<?>> outputs)

getBatchConfig

public BatchResequencerConfig getBatchConfig()

getBatchConfig

public BatchResequencerConfig getBatchConfig(BatchResequencerConfig defaultConfig)

getStreamConfig

public StreamResequencerConfig getStreamConfig()

setBatchConfig

public void setBatchConfig(BatchResequencerConfig batchConfig)

setStreamConfig

public void setStreamConfig(StreamResequencerConfig streamConfig)

timeout

public ResequencerType timeout(long timeout)

size

public ResequencerType size(int batchSize)

capacity

public ResequencerType capacity(int capacity)

comparator

public ResequencerType comparator(ExpressionResultComparator<Exchange> comparator)

createProcessor

public Processor createProcessor(RouteContext routeContext)
                          throws Exception
Overrides:
createProcessor in class ProcessorType<ProcessorType>
Throws:
Exception

createBatchResequencer

protected Resequencer createBatchResequencer(RouteContext routeContext,
                                             BatchResequencerConfig config)
                                      throws Exception
Creates a batch Resequencer instance applying the given config.

Parameters:
routeContext - route context.
config - batch resequencer configuration.
Returns:
the configured batch resequencer.
Throws:
Exception

createStreamResequencer

protected StreamResequencer createStreamResequencer(RouteContext routeContext,
                                                    StreamResequencerConfig config)
                                             throws Exception
Creates a StreamResequencer instance applying the given config.

Parameters:
routeContext - route context.
config - stream resequencer configuration.
Returns:
the configured stream resequencer.
Throws:
Exception


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