org.apache.camel.model
Class ThreadType
java.lang.Object
org.apache.camel.model.OptionalIdentifiedType<Type>
org.apache.camel.model.ProcessorType<ProcessorType>
org.apache.camel.model.ThreadType
- All Implemented Interfaces:
- Block
public class ThreadType
- extends ProcessorType<ProcessorType>
Represents an XML <thread/> element
- Version:
- $Revision: 1456 $
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, convertBodyTo, convertBodyTo, convertFaultBodyTo, convertOutBodyTo, createCompositeProcessor, createErrorHandlerBuilder, createOutputsProcessor, createOutputsProcessor, delayer, delayer, delayer, delayer, end, exception, filter, filter, filter, filter, getErrorHandlerBuilder, getErrorHandlerRef, getInheritErrorHandlerFlag, getLabel, 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 |
ThreadType
public ThreadType()
ThreadType
public ThreadType(int coreSize)
ThreadType
public ThreadType(ThreadPoolExecutor executor)
getOutputs
public List<ProcessorType<?>> getOutputs()
- Specified by:
getOutputs
in class ProcessorType<ProcessorType>
toString
public String toString()
- Overrides:
toString
in class Object
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
createProcessor
public Processor createProcessor(RouteContext routeContext)
throws Exception
- Overrides:
createProcessor
in class ProcessorType<ProcessorType>
- Throws:
Exception
configureChild
protected void configureChild(ProcessorType output)
- Overrides:
configureChild
in class ProcessorType<ProcessorType>
errorHandler
public ProcessorType errorHandler(ErrorHandlerBuilder errorHandlerBuilder)
- Description copied from class:
ProcessorType
- Installs the given error handler builder
- Overrides:
errorHandler
in class ProcessorType<ProcessorType>
- Parameters:
errorHandlerBuilder
- the error handler to be used by default for
all child routes
- Returns:
- the current builder with the error handler configured
coreSize
public ThreadType coreSize(int coreSize)
daemon
public ThreadType daemon(boolean daemon)
keepAliveTime
public ThreadType keepAliveTime(long keepAliveTime)
maxSize
public ThreadType maxSize(int maxSize)
name
public ThreadType name(String name)
priority
public ThreadType priority(int priority)
stackSize
public ThreadType stackSize(long stackSize)
taskQueue
public ThreadType taskQueue(BlockingQueue<Runnable> taskQueue)
threadGroup
public ThreadType threadGroup(ThreadGroup threadGroup)
executor
public ThreadType executor(ThreadPoolExecutor executor)
setCoreSize
public void setCoreSize(int coreSize)
setDaemon
public void setDaemon(boolean daemon)
setKeepAliveTime
public void setKeepAliveTime(long keepAliveTime)
setMaxSize
public void setMaxSize(int maxSize)
setName
public void setName(String name)
setPriority
public void setPriority(int priority)
setStackSize
public void setStackSize(long stackSize)
setTaskQueue
public void setTaskQueue(BlockingQueue<Runnable> taskQueue)
setThreadGroup
public void setThreadGroup(ThreadGroup threadGroup)
getExecutor
public ThreadPoolExecutor getExecutor()
setExecutor
public void setExecutor(ThreadPoolExecutor executor)
Copyright © 2009 IONA Open Source Community. All Rights Reserved.