@Metadata(label="eip,endpoint,routing") public class WireTapDefinition<Type extends ProcessorDefinition<Type>> extends ToDynamicDefinition implements ExecutorServiceAwareDefinition<WireTapDefinition<Type>>
inheritErrorHandler, log| Constructor and Description |
|---|
WireTapDefinition() |
| Modifier and Type | Method and Description |
|---|---|
void |
addOutput(ProcessorDefinition<?> output)
Adds the given definition as output to this block
|
WireTapDefinition<Type> |
cacheSize(int cacheSize)
Sets the maximum size used by the
ProducerCache which is used
to cache and reuse producers, when uris are reused. |
WireTapDefinition<Type> |
copy()
Uses a copy of the original exchange
|
WireTapDefinition<Type> |
copy(boolean copy)
Uses a copy of the original exchange
|
Processor |
createProcessor(RouteContext routeContext)
Override this in definition class and implement logic to create the processor
based on the definition model.
|
Type |
end()
Ends the current block
|
WireTapDefinition<Type> |
executorService(ExecutorService executorService)
Uses a custom thread pool
|
WireTapDefinition<Type> |
executorServiceRef(String executorServiceRef)
Uses a custom thread pool
|
Boolean |
getCopy() |
ExecutorService |
getExecutorService()
Gets the executor service
|
String |
getExecutorServiceRef()
Gets the reference to lookup in the
Registry for the executor service to be used. |
List<SetHeaderDefinition> |
getHeaders() |
String |
getLabel()
Returns a label to describe this node such as the expression if some kind of expression node
|
ExpressionSubElementDefinition |
getNewExchangeExpression() |
Processor |
getNewExchangeProcessor() |
String |
getNewExchangeProcessorRef() |
Processor |
getOnPrepare() |
String |
getOnPrepareRef() |
ExchangePattern |
getPattern() |
String |
getUri() |
WireTapDefinition<Type> |
ignoreInvalidEndpoint()
Ignore the invalidate endpoint exception when try to create a producer with that endpoint
|
WireTapDefinition<Type> |
newExchange(Expression expression)
Deprecated.
will be removed in Camel 3.0 Instead use
newExchangeBody(org.apache.camel.Expression) |
WireTapDefinition<Type> |
newExchange(Processor processor)
Sends a new Exchange, instead of tapping an existing, using
ExchangePattern.InOnly |
WireTapDefinition<Type> |
newExchangeBody(Expression expression)
Sends a new Exchange, instead of tapping an existing, using
ExchangePattern.InOnly |
WireTapDefinition<Type> |
newExchangeHeader(String headerName,
Expression expression)
Sets a header on the new Exchange, instead of tapping an existing, using
ExchangePattern.InOnly. |
WireTapDefinition<Type> |
newExchangeRef(String ref)
Sends a new Exchange, instead of tapping an existing, using
ExchangePattern.InOnly |
WireTapDefinition<Type> |
onPrepare(Processor onPrepare)
|
WireTapDefinition<Type> |
onPrepareRef(String onPrepareRef)
|
void |
setCopy(Boolean copy) |
void |
setExecutorService(ExecutorService executorService)
Sets the executor service to be used.
|
void |
setExecutorServiceRef(String executorServiceRef)
Sets a reference to lookup in the
Registry for the executor service to be used. |
void |
setHeaders(List<SetHeaderDefinition> headers) |
void |
setNewExchangeExpression(ExpressionSubElementDefinition newExchangeExpression)
Uses the expression for creating a new body as the message to use for wire tapping
|
void |
setNewExchangeProcessor(Processor processor)
To use a Processor for creating a new body as the message to use for wire tapping
|
void |
setNewExchangeProcessorRef(String ref)
Reference to a Processor to use for creating a new body as the message to use for wire tapping
|
void |
setOnPrepare(Processor onPrepare) |
void |
setOnPrepareRef(String onPrepareRef) |
void |
setUri(String uri)
The uri of the endpoint to wiretap to.
|
String |
toString() |
createExpression, getCacheSize, getIgnoreInvalidEndpoint, pattern, setCacheSize, setIgnoreInvalidEndpoint, setPatterngetOutputs, isOutputSupportedaddInterceptStrategies, addInterceptStrategy, addRoutes, aggregate, aggregate, aggregate, aggregate, aop, attribute, bean, bean, bean, bean, bean, bean, bean, bean, beanRef, beanRef, beanRef, beanRef, beanRef, choice, clearOutput, configureChild, convertBodyTo, convertBodyTo, createChannel, createChildProcessor, createCompositeProcessor, createOutputsProcessor, createOutputsProcessor, createOutputsProcessorImpl, createProcessor, delay, delay, delay, doTry, dynamicRouter, dynamicRouter, endChoice, endDoTry, endParent, endRest, enrich, enrich, enrich, enrich, enrich, enrichRef, enrichRef, enrichRef, filter, filter, filter, filter, getIndex, getInterceptStrategies, getOtherAttributes, getParent, id, idempotentConsumer, idempotentConsumer, idempotentConsumer, inheritErrorHandler, inOnly, inOnly, inOnly, inOnly, inOnly, inOnly, inOut, inOut, inOut, inOut, inOut, inOut, isAbstract, isInheritErrorHandler, isTopLevelOnly, loadBalance, loadBalance, log, log, log, log, log, log, loop, loop, loop, loopDoWhile, makeProcessor, markRollbackOnly, markRollbackOnlyLast, marshal, marshal, marshal, marshal, multicast, multicast, multicast, onCompletion, onException, onException, pipeline, pipeline, pipeline, pipeline, placeholder, policy, policy, pollEnrich, pollEnrich, pollEnrich, pollEnrich, pollEnrich, pollEnrich, pollEnrich, pollEnrichRef, pollEnrichRef, preCreateProcessor, process, process, processRef, recipientList, recipientList, recipientList, recipientList, removeFaultHeader, removeHeader, removeHeaders, removeHeaders, removeProperties, removeProperties, removeProperty, resequence, resequence, rollback, rollback, routeDescription, routeId, routingSlip, routingSlip, routingSlip, routingSlip, routingSlip, routingSlip, routingSlip, sample, sample, sample, script, script, setBody, setBody, setExchangePattern, setFaultBody, setFaultHeader, setHeader, setHeader, setInheritErrorHandler, setOtherAttributes, setOutHeader, setOutHeader, setParent, setProperty, setProperty, sort, sort, sort, split, split, split, startupOrder, stop, threads, threads, threads, threads, throttle, throttle, throwException, throwException, to, to, to, to, to, to, to, to, to, to, toD, toD, toF, transacted, transacted, transform, transform, unmarshal, unmarshal, unmarshal, unmarshal, validate, validate, validate, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap, wireTap, wrapChannel, wrapInErrorHandler, wrapProcessordescription, description, getCustomId, getDescription, getDescriptionText, getId, getShortName, hasCustomIdAssigned, idOrCreate, setCustomId, setDescription, setIdpublic WireTapDefinition()
public Processor createProcessor(RouteContext routeContext) throws Exception
ProcessorDefinitioncreateProcessor in class ToDynamicDefinitionExceptionpublic ExchangePattern getPattern()
getPattern in class ToDynamicDefinitionpublic String toString()
toString in class ToDynamicDefinitionpublic String getLabel()
ProcessorDefinitiongetLabel in interface NamedNodegetLabel in class ProcessorDefinition<ToDynamicDefinition>public Type end()
ProcessorDefinitionend in class ProcessorDefinition<ToDynamicDefinition>public void addOutput(ProcessorDefinition<?> output)
BlockaddOutput in interface BlockaddOutput in class ProcessorDefinition<ToDynamicDefinition>output - the processor definitionpublic WireTapDefinition<Type> executorService(ExecutorService executorService)
executorService in interface ExecutorServiceAwareDefinition<WireTapDefinition<Type extends ProcessorDefinition<Type>>>executorService - a custom ExecutorService to use as thread pool
for sending tapped exchangespublic WireTapDefinition<Type> executorServiceRef(String executorServiceRef)
executorServiceRef in interface ExecutorServiceAwareDefinition<WireTapDefinition<Type extends ProcessorDefinition<Type>>>executorServiceRef - reference to lookup a custom ExecutorService
to use as thread pool for sending tapped exchangespublic WireTapDefinition<Type> copy()
public WireTapDefinition<Type> copy(boolean copy)
copy - if it is true camel will copy the original exchange,
if it is false camel will not copy the original exchange@Deprecated public WireTapDefinition<Type> newExchange(Expression expression)
newExchangeBody(org.apache.camel.Expression)public WireTapDefinition<Type> newExchangeBody(Expression expression)
ExchangePattern.InOnlyexpression - expression that creates the new body to sendnewExchangeHeader(String, org.apache.camel.Expression)public WireTapDefinition<Type> newExchangeRef(String ref)
ExchangePattern.InOnlypublic WireTapDefinition<Type> newExchange(Processor processor)
ExchangePattern.InOnlyprocessor - processor preparing the new exchange to sendnewExchangeHeader(String, org.apache.camel.Expression)public WireTapDefinition<Type> newExchangeHeader(String headerName, Expression expression)
ExchangePattern.InOnly.
Use this together with the newExchange(org.apache.camel.Expression) or newExchange(org.apache.camel.Processor)
methods.headerName - the header nameexpression - the expression setting the header valuepublic WireTapDefinition<Type> onPrepare(Processor onPrepare)
Processor when preparing the Exchange to be send.
This can be used to deep-clone messages that should be send, or any custom logic needed before
the exchange is send.onPrepare - the processorpublic WireTapDefinition<Type> onPrepareRef(String onPrepareRef)
Processor when preparing the Exchange to be send.
This can be used to deep-clone messages that should be send, or any custom logic needed before
the exchange is send.onPrepareRef - reference to the processor to lookup in the Registrypublic WireTapDefinition<Type> cacheSize(int cacheSize)
ProducerCache which is used
to cache and reuse producers, when uris are reused.cacheSize in class ToDynamicDefinitioncacheSize - the cache size, use 0 for default cache size, or -1 to turn cache off.public WireTapDefinition<Type> ignoreInvalidEndpoint()
ignoreInvalidEndpoint in class ToDynamicDefinitionpublic String getUri()
getUri in class ToDynamicDefinitionpublic void setUri(String uri)
SimpleLanguage expression.setUri in class ToDynamicDefinitionpublic Processor getNewExchangeProcessor()
public void setNewExchangeProcessor(Processor processor)
public String getNewExchangeProcessorRef()
public void setNewExchangeProcessorRef(String ref)
public ExpressionSubElementDefinition getNewExchangeExpression()
public void setNewExchangeExpression(ExpressionSubElementDefinition newExchangeExpression)
public ExecutorService getExecutorService()
ExecutorServiceAwaregetExecutorService in interface ExecutorServiceAwarepublic void setExecutorService(ExecutorService executorService)
ExecutorServiceAwaresetExecutorService in interface ExecutorServiceAwareexecutorService - the executorpublic String getExecutorServiceRef()
ExecutorServiceAwareRegistry for the executor service to be used.getExecutorServiceRef in interface ExecutorServiceAwarepublic void setExecutorServiceRef(String executorServiceRef)
ExecutorServiceAwareRegistry for the executor service to be used.setExecutorServiceRef in interface ExecutorServiceAwareexecutorServiceRef - reference for the executorpublic String getOnPrepareRef()
public void setOnPrepareRef(String onPrepareRef)
public Processor getOnPrepare()
public void setOnPrepare(Processor onPrepare)
public List<SetHeaderDefinition> getHeaders()
public void setHeaders(List<SetHeaderDefinition> headers)
Apache Camel