Package org.apache.camel.reifier
Class AggregateReifier
- java.lang.Object
-
- org.apache.camel.reifier.AbstractReifier
-
- org.apache.camel.reifier.ProcessorReifier<org.apache.camel.model.AggregateDefinition>
-
- org.apache.camel.reifier.AggregateReifier
-
- All Implemented Interfaces:
org.apache.camel.spi.BeanRepository
public class AggregateReifier extends ProcessorReifier<org.apache.camel.model.AggregateDefinition>
-
-
Field Summary
-
Fields inherited from class org.apache.camel.reifier.ProcessorReifier
definition
-
Fields inherited from class org.apache.camel.reifier.AbstractReifier
camelContext, route
-
-
Constructor Summary
Constructors Constructor Description AggregateReifier(org.apache.camel.Route route, org.apache.camel.model.ProcessorDefinition<?> definition)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected org.apache.camel.processor.aggregate.AggregateProcessor
createAggregator()
org.apache.camel.processor.aggregate.OptimisticLockRetryPolicy
createOptimisticLockRetryPolicy(org.apache.camel.model.OptimisticLockRetryPolicyDefinition definition)
org.apache.camel.Processor
createProcessor()
Override this in definition class and implement logic to create the processor based on the definition model.-
Methods inherited from class org.apache.camel.reifier.ProcessorReifier
addRoutes, clearReifiers, configureChild, coreReifier, createChildProcessor, createCompositeProcessor, createOutputsProcessor, createOutputsProcessor, createProcessor, getConfiguredExecutorService, getConfiguredScheduledExecutorService, getId, hasOutputs, lookupExecutorServiceRef, lookupScheduledExecutorServiceRef, makeProcessor, preCreateProcessor, registerReifier, reifier, willCreateNewThreadPool, wrapChannel, wrapChannel, wrapInErrorHandler, wrapProcessor
-
Methods inherited from class org.apache.camel.reifier.AbstractReifier
asRef, createExpression, createExpression, createPredicate, createPredicate, findByType, findByTypeWithName, findSingleByType, getRegistry, lookup, lookupByName, lookupByNameAndType, mandatoryLookup, or, parse, parse, parseBoolean, parseBoolean, parseDuration, parseDuration, parseFloat, parseFloat, parseInt, parseInt, parseLong, parseLong, parseString, resolveEndpoint, unwrap
-
-
-
-
Method Detail
-
createProcessor
public org.apache.camel.Processor createProcessor() throws Exception
Description copied from class:ProcessorReifier
Override this in definition class and implement logic to create the processor based on the definition model.- Specified by:
createProcessor
in classProcessorReifier<org.apache.camel.model.AggregateDefinition>
- Throws:
Exception
-
createAggregator
protected org.apache.camel.processor.aggregate.AggregateProcessor createAggregator() throws Exception
- Throws:
Exception
-
createOptimisticLockRetryPolicy
public org.apache.camel.processor.aggregate.OptimisticLockRetryPolicy createOptimisticLockRetryPolicy(org.apache.camel.model.OptimisticLockRetryPolicyDefinition definition)
-
-