Uses of Interface
org.apache.camel.Processor

Packages that use Processor

org.apache.camel	The JAXB POJOs for the XML Configuration of the routing rules.
org.apache.camel.bam
org.apache.camel.bam.processor
org.apache.camel.bam.rules
org.apache.camel.builder	The Camel Domain Specific Language for creating Routes, Predicates, Expressions and Error Handlers.
org.apache.camel.builder.script
org.apache.camel.builder.xml	Support for XPath based Expressions and Predicates as well as an XSLT processor
org.apache.camel.component	Base classes for Spring based Components
org.apache.camel.component.ahc
org.apache.camel.component.apns
org.apache.camel.component.atom
org.apache.camel.component.aws.s3
org.apache.camel.component.aws.sns
org.apache.camel.component.aws.sqs
org.apache.camel.component.bean	The Bean Component which will look up the bean name in the Spring ApplicationContext and use that to dispatch messages to a POJO
org.apache.camel.component.bean.validator	The Bean Validator Component for validating java Beans using the JSR 303 reference implementation (Hibernate Validator)
org.apache.camel.component.browse	The Browse Component which is a simple in memory component which maintains a list of all message exchanges which can be useful for debugging, tooling or visualistion.
org.apache.camel.component.cache
org.apache.camel.component.cometd
org.apache.camel.component.crypto
org.apache.camel.component.crypto.processor
org.apache.camel.component.cxf	Defines the CXF Component
org.apache.camel.component.cxf.cxfbean
org.apache.camel.component.cxf.jaxrs
org.apache.camel.component.cxf.transport
org.apache.camel.component.dataset	A DataSet Endpoint for testing of endpoints using defined DataSets
org.apache.camel.component.direct	The Direct Component which synchronously invokes all the consumers when a producer sends an exchange to the endpoint.
org.apache.camel.component.dns
org.apache.camel.component.event	An Event Endpoint for working with Spring ApplicationEvents
org.apache.camel.component.eventadmin
org.apache.camel.component.exec
org.apache.camel.component.feed
org.apache.camel.component.file	The File Component for working with file systems.
org.apache.camel.component.file.remote	Defines the File transport for communicating with Remote Files and FTP
org.apache.camel.component.flatpack	The Flatpack Component for working with fixed width or delimited files
org.apache.camel.component.gae.auth
org.apache.camel.component.gae.http
org.apache.camel.component.gae.login
org.apache.camel.component.gae.mail
org.apache.camel.component.gae.task
org.apache.camel.component.hazelcast
org.apache.camel.component.hazelcast.atomicnumber
org.apache.camel.component.hazelcast.instance
org.apache.camel.component.hazelcast.list
org.apache.camel.component.hazelcast.map
org.apache.camel.component.hazelcast.multimap
org.apache.camel.component.hazelcast.queue
org.apache.camel.component.hazelcast.seda
org.apache.camel.component.hdfs
org.apache.camel.component.http	Defines the HTTP Component
org.apache.camel.component.http4	Defines the HTTP Component
org.apache.camel.component.ibatis
org.apache.camel.component.irc	Defines the IRC Component
org.apache.camel.component.javaspace
org.apache.camel.component.jcr
org.apache.camel.component.jdbc	Defines an JDBC component that can bind to JDBC datasources.
org.apache.camel.component.jetty	Defines the Jetty HTTP Component
org.apache.camel.component.jms	Defines the JMS Component
org.apache.camel.component.jmx
org.apache.camel.component.jpa	Defines the JPA component for polling databases or recording messages in a database.
org.apache.camel.component.jt400
org.apache.camel.component.kestrel
org.apache.camel.component.language	The Language Component to send messages to language endpoints executing the script.
org.apache.camel.component.ldap
org.apache.camel.component.log	The Log Component uses Jakarta Commons Logging to log message exchanges.
org.apache.camel.component.lucene
org.apache.camel.component.mail	Defines the Email Component
org.apache.camel.component.mina
org.apache.camel.component.mock	The Mock Component which is used for testing of routing and mediation rules.
org.apache.camel.component.mybatis
org.apache.camel.component.nagios
org.apache.camel.component.netty
org.apache.camel.component.paxlogging
org.apache.camel.component.printer
org.apache.camel.component.quartz	Defines the Quartz Component
org.apache.camel.component.quickfixj
org.apache.camel.component.restlet
org.apache.camel.component.rmi	Defines an RMI Component that can bind PojoExchanges to the Java Remote Method Protocol (JRMP).
org.apache.camel.component.routebox.direct
org.apache.camel.component.routebox.seda
org.apache.camel.component.rss
org.apache.camel.component.seda	The SEDA Component for asynchronous SEDA exchanges on a BlockingQueue within a single CamelContext
org.apache.camel.component.servlet
org.apache.camel.component.shiro.security
org.apache.camel.component.sip
org.apache.camel.component.smpp
org.apache.camel.component.snmp
org.apache.camel.component.spring.integration
org.apache.camel.component.spring.integration.adapter
org.apache.camel.component.spring.security
org.apache.camel.component.spring.ws
org.apache.camel.component.sql	Defines an SQL component that can bind to JDBC datasources and execute SQL queries that are exposed as endpoints.
org.apache.camel.component.stream
org.apache.camel.component.stringtemplate
org.apache.camel.component.timer	The Timer Component extends the POJO component to provide a simple timer
org.apache.camel.component.validator	The Validator Component for validating XML against some schema
org.apache.camel.component.validator.jing
org.apache.camel.component.xmpp	Defines the XMPP transport for communicating over Jabber
org.apache.camel.component.xquery	The XQuery Component for transforming messages with XQuery
org.apache.camel.converter	A set of helper classes for converting from different types of Java object to be used by the Type Conversion Support
org.apache.camel.core.osgi
org.apache.camel.example.gae
org.apache.camel.example.gauth
org.apache.camel.example.service
org.apache.camel.fabric
org.apache.camel.impl	Default implementation classes for Camel Core
org.apache.camel.impl.converter	Default implementation classes the Type Conversion Strategies
org.apache.camel.loanbroker.queue.version
org.apache.camel.management	Camel management
org.apache.camel.management.event	Camel management events
org.apache.camel.management.mbean	Camel management JMX Mbeans
org.apache.camel.model	The JAXB POJOs for the XML Configuration of the routing rules.
org.apache.camel.model.loadbalancer	The Load Balancer EIP pattern
org.apache.camel.processor	A collection of Processor implementations which are used to implement the Enterprise Integration Patterns
org.apache.camel.processor.aggregate	Helper classes for the Aggregator pattern.
org.apache.camel.processor.cache
org.apache.camel.processor.idempotent	An implementation of the Idempotent Consumer pattern.
org.apache.camel.processor.interceptor	Helper classes for interceptors.
org.apache.camel.processor.loadbalancer	Various load balancer processors
org.apache.camel.processor.lucene
org.apache.camel.processor.validation	Performs XML validation using JAXP for validating against XSD or RelaxNG
org.apache.camel.spi	Service Provider Interfaces used internally by the Camel runtime which are plugin strategies.
org.apache.camel.spring.spi	Plugins to the CamleContext when running in Spring
org.apache.camel.test
org.apache.camel.test.junit4
org.apache.camel.testng
org.apache.camel.util	Utility classes used by the core of Camel and useful for Camel component developers

Uses of Processor in org.apache.camel

Subinterfaces of Processor in org.apache.camel

interface	AsyncProcessor An asynchronous processor which can process an Exchange in an asynchronous fashion and signal completion by invoking the AsyncCallback.
interface	Channel Channel acts as a channel between Processors in the route graph.
interface	Producer Provides a channel on which clients can create and invoke message exchanges on an Endpoint

Methods in org.apache.camel that return Processor

Processor	Channel.getErrorHandler() Gets the ErrorHandler this Channel uses.
Processor	Channel.getNextProcessor() Gets the next Processor to route to (not wrapped)
Processor	Channel.getOutput() Gets the wrapped output that at runtime should be delegated to.
Processor	RouteNode.getProcessor() Gets the actual processor this node represents.

Methods in org.apache.camel that return types with arguments of type Processor

Navigate<Processor>

Route.navigate() Returns a navigator to navigate this route by navigating all the Processors.

Methods in org.apache.camel with parameters of type Processor

Future<Exchange>	ProducerTemplate.asyncCallback(Endpoint endpoint, Processor processor, Synchronization onCompletion) Sends an asynchronous exchange to the given endpoint using a supplied processor.
Future<Exchange>	ProducerTemplate.asyncCallback(String endpointUri, Processor processor, Synchronization onCompletion) Sends an asynchronous exchange to the given endpoint using a supplied processor.
Future<Exchange>	ProducerTemplate.asyncSend(Endpoint endpoint, Processor processor) Sends an asynchronous exchange to the given endpoint.
Future<Exchange>	ProducerTemplate.asyncSend(String endpointUri, Processor processor) Sends an asynchronous exchange to the given endpoint.
Consumer	Endpoint.createConsumer(Processor processor) Creates a new Event Driven Consumer which consumes messages from the endpoint using the given processor
Exchange	ProducerTemplate.request(Endpoint endpoint, Processor processor) Sends an exchange to an endpoint using a supplied processor Uses an ExchangePattern.InOut message exchange pattern.
Exchange	ProducerTemplate.request(String endpointUri, Processor processor) Sends an exchange to an endpoint using a supplied processor Uses an ExchangePattern.InOut message exchange pattern.
Exchange	ProducerTemplate.send(Endpoint endpoint, ExchangePattern pattern, Processor processor) Sends an exchange to an endpoint using a supplied processor Notice: that if the processing of the exchange failed with an Exception it is not thrown from this method, but you can access it from the returned exchange using Exchange.getException().
Exchange	ProducerTemplate.send(Endpoint endpoint, Processor processor) Sends an exchange to an endpoint using a supplied processor Notice: that if the processing of the exchange failed with an Exception it is not thrown from this method, but you can access it from the returned exchange using Exchange.getException().
Exchange	ProducerTemplate.send(Processor processor) Sends an exchange to the default endpoint using a supplied processor Notice: that if the processing of the exchange failed with an Exception it is not thrown from this method, but you can access it from the returned exchange using Exchange.getException().
Exchange	ProducerTemplate.send(String endpointUri, ExchangePattern pattern, Processor processor) Sends an exchange to an endpoint using a supplied processor Notice: that if the processing of the exchange failed with an Exception it is not thrown from this method, but you can access it from the returned exchange using Exchange.getException().
Exchange	ProducerTemplate.send(String endpointUri, Processor processor) Sends an exchange to an endpoint using a supplied processor Notice: that if the processing of the exchange failed with an Exception it is not thrown from this method, but you can access it from the returned exchange using Exchange.getException().
void	Channel.setErrorHandler(Processor errorHandler) Sets the ErrorHandler this Channel uses.
void	Channel.setNextProcessor(Processor next) Sets the processor that the channel should route the Exchange to.
void	Channel.setOutput(Processor output) Sets the wrapped output that at runtime should be delegated to.

Uses of Processor in org.apache.camel.bam

Methods in org.apache.camel.bam that return Processor

Processor	ProcessBuilder.createActivityProcessor(ActivityBuilder activityBuilder)
Processor	ActivityBuilder.createProcessor()
Processor	ActivityBuilder.getProcessor() Returns the processor of the route

Uses of Processor in org.apache.camel.bam.processor

Classes in org.apache.camel.bam.processor that implement Processor

class	BamProcessorSupport<T> A base Processor for working on BAM which a derived class would do the actual persistence such as the JpaBamProcessor
class	JpaBamProcessor A concrete Processor for working on BAM which uses JPA as the persistence and uses the ProcessInstance entity to store the process information.
class	JpaBamProcessorSupport<T> A base class for JPA based BAM which can use any entity to store the process instance information which allows derived classes to specialise the process instance entity.

Uses of Processor in org.apache.camel.bam.rules

Methods in org.apache.camel.bam.rules that return Processor

Processor

TemporalRule.getOverdueAction()

Uses of Processor in org.apache.camel.builder

Fields in org.apache.camel.builder declared as Processor

protected Processor	DefaultErrorHandlerBuilder.failureProcessor
protected Processor	DefaultErrorHandlerBuilder.onRedelivery

Methods in org.apache.camel.builder that return Processor

Processor	NoErrorHandlerBuilder.createErrorHandler(RouteContext routeContext, Processor processor)
Processor	LoggingErrorHandlerBuilder.createErrorHandler(RouteContext routeContext, Processor processor)
Processor	ErrorHandlerBuilderRef.createErrorHandler(RouteContext routeContext, Processor processor)
Processor	ErrorHandlerBuilder.createErrorHandler(RouteContext routeContext, Processor processor) Creates the error handler interceptor
Processor	DefaultErrorHandlerBuilder.createErrorHandler(RouteContext routeContext, Processor processor)
Processor	DeadLetterChannelBuilder.createErrorHandler(RouteContext routeContext, Processor processor)
Processor	DefaultErrorHandlerBuilder.getFailureProcessor()
Processor	DeadLetterChannelBuilder.getFailureProcessor()
Processor	DefaultErrorHandlerBuilder.getOnRedelivery()
static Processor	ProcessorBuilder.removeFaultHeader(String name) Deprecated. will be removed in the near future. Instead use ProcessorBuilder.removeHeader(String)
static Processor	ProcessorBuilder.removeHeader(String name) Removes the header on the IN message
static Processor	ProcessorBuilder.removeHeaders(String pattern) Removes the headers on the IN message
static Processor	ProcessorBuilder.removeHeaders(String pattern, String... exceptionPatterns) Removes all headers on the IN message, except for the ones provided in the names parameter
static Processor	ProcessorBuilder.removeProperty(String name) Removes the property on the exchange
static Processor	ProcessorBuilder.setBody(Expression expression) Creates a processor which sets the body of the IN message to the value of the expression
static Processor	ProcessorBuilder.setFaultBody(Expression expression) Creates a processor which sets the body of the FAULT message to the value of the expression
static Processor	ProcessorBuilder.setFaultHeader(String name, Expression expression) Sets the header on the FAULT message
static Processor	ProcessorBuilder.setHeader(String name, Expression expression) Sets the header on the IN message
static Processor	ProcessorBuilder.setOutBody(Expression expression) Creates a processor which sets the body of the OUT message to the value of the expression
static Processor	ProcessorBuilder.setOutHeader(String name, Expression expression) Sets the header on the OUT message
static Processor	ProcessorBuilder.setProperty(String name, Expression expression) Sets the property on the exchange
static Processor	ProcessorBuilder.throwException(Exception ex) Throws an exception

Methods in org.apache.camel.builder with parameters of type Processor

Processor	NoErrorHandlerBuilder.createErrorHandler(RouteContext routeContext, Processor processor)
Processor	LoggingErrorHandlerBuilder.createErrorHandler(RouteContext routeContext, Processor processor)
Processor	ErrorHandlerBuilderRef.createErrorHandler(RouteContext routeContext, Processor processor)
Processor	ErrorHandlerBuilder.createErrorHandler(RouteContext routeContext, Processor processor) Creates the error handler interceptor
Processor	DefaultErrorHandlerBuilder.createErrorHandler(RouteContext routeContext, Processor processor)
Processor	DeadLetterChannelBuilder.createErrorHandler(RouteContext routeContext, Processor processor)
DefaultErrorHandlerBuilder	DefaultErrorHandlerBuilder.onRedelivery(Processor processor) Sets a processor that should be processed before a redelivery attempt.
void	DefaultErrorHandlerBuilder.setFailureProcessor(Processor failureProcessor)
void	DefaultErrorHandlerBuilder.setOnRedelivery(Processor onRedelivery)

Uses of Processor in org.apache.camel.builder.script

Classes in org.apache.camel.builder.script that implement Processor

class

ScriptBuilder A builder class for creating Processor, Expression and Predicate objects using the JSR 223 scripting engine.

Uses of Processor in org.apache.camel.builder.xml

Classes in org.apache.camel.builder.xml that implement Processor

class

XsltBuilder Creates a Processor which performs an XSLT transformation of the IN message body.

Uses of Processor in org.apache.camel.component

Constructors in org.apache.camel.component with parameters of type Processor

ResourceBasedEndpoint(String endpointUri, Component component, String resourceUri, Processor processor)

ResourceBasedEndpoint(String endpointUri, Processor processor, String resourceUri)

Uses of Processor in org.apache.camel.component.ahc

Classes in org.apache.camel.component.ahc that implement Processor

class

AhcProducer

Methods in org.apache.camel.component.ahc with parameters of type Processor

Consumer

AhcEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.apns

Classes in org.apache.camel.component.apns that implement Processor

class

ApnsProducer

Methods in org.apache.camel.component.apns with parameters of type Processor

Consumer

ApnsEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.apns with parameters of type Processor

ApnsConsumer(ApnsEndpoint apnsEndpoint, Processor processor)

Uses of Processor in org.apache.camel.component.atom

Classes in org.apache.camel.component.atom that implement Processor

class

AtomProducer AtomProducer is currently not implemented

Methods in org.apache.camel.component.atom with parameters of type Processor

protected FeedPollingConsumer	AtomEndpoint.createEntryPollingConsumer(FeedEndpoint feedEndpoint, Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)
protected FeedPollingConsumer	AtomEndpoint.createPollingConsumer(FeedEndpoint feedEndpoint, Processor processor)

Constructors in org.apache.camel.component.atom with parameters of type Processor

AtomEntryPollingConsumer(AtomEndpoint endpoint, Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)

AtomPollingConsumer(AtomEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.aws.s3

Classes in org.apache.camel.component.aws.s3 that implement Processor

class

S3Producer A Producer which sends messages to the Amazon Web Service Simple Storage Service AWS S3

Methods in org.apache.camel.component.aws.s3 with parameters of type Processor

Consumer

S3Endpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.aws.s3 with parameters of type Processor

S3Consumer(S3Endpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.aws.sns

Classes in org.apache.camel.component.aws.sns that implement Processor

class

SnsProducer A Producer which sends messages to the Amazon Web Service Simple Notification Service AWS SNS

Methods in org.apache.camel.component.aws.sns with parameters of type Processor

Consumer

SnsEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.aws.sqs

Classes in org.apache.camel.component.aws.sqs that implement Processor

class

SqsProducer A Producer which sends messages to the Amazon Web Service Simple Queue Service AWS SQS

Methods in org.apache.camel.component.aws.sqs with parameters of type Processor

Consumer

SqsEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.aws.sqs with parameters of type Processor

SqsConsumer(SqsEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.bean

Classes in org.apache.camel.component.bean that implement Processor

class

BeanProcessor A Processor which converts the inbound exchange to a method invocation on a POJO

Methods in org.apache.camel.component.bean that return Processor

protected Processor	BeanEndpoint.createProcessor()
Processor	RegistryBean.getProcessor()
Processor	ConstantBeanHolder.getProcessor()
protected Processor	BeanProcessor.getProcessor()
Processor	BeanHolder.getProcessor()

Uses of Processor in org.apache.camel.component.bean.validator

Classes in org.apache.camel.component.bean.validator that implement Processor

class

BeanValidator Bean validator that uses the JSR 303 reference implementation (Hibernate Validator).

Uses of Processor in org.apache.camel.component.browse

Methods in org.apache.camel.component.browse with parameters of type Processor

Consumer

BrowseEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.cache

Classes in org.apache.camel.component.cache that implement Processor

class

CacheProducer

Methods in org.apache.camel.component.cache with parameters of type Processor

Consumer

CacheEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.cache with parameters of type Processor

CacheConsumer(Endpoint endpoint, Processor processor, CacheConfiguration config)

Uses of Processor in org.apache.camel.component.cometd

Classes in org.apache.camel.component.cometd that implement Processor

class

CometdProducer A Producer to send messages using Cometd and Bayeux protocol.

Methods in org.apache.camel.component.cometd with parameters of type Processor

Consumer

CometdEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.cometd with parameters of type Processor

CometdConsumer(CometdEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.crypto

Classes in org.apache.camel.component.crypto that implement Processor

class

DigitalSignatureProducer DigitalSignatureProducer

Methods in org.apache.camel.component.crypto with parameters of type Processor

Consumer

DigitalSignatureEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.crypto.processor

Classes in org.apache.camel.component.crypto.processor that implement Processor

class	DigitalSignatureProcessor
class	SigningProcessor
class	VerifyingProcessor VerifyingProcessor

Uses of Processor in org.apache.camel.component.cxf

Classes in org.apache.camel.component.cxf that implement Processor

class

CxfProducer CxfProducer binds a Camel exchange to a CXF exchange, acts as a CXF client, and sends the request to a CXF to a server.

Methods in org.apache.camel.component.cxf with parameters of type Processor

Consumer

CxfEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.cxf with parameters of type Processor

CxfConsumer(CxfEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.cxf.cxfbean

Classes in org.apache.camel.component.cxf.cxfbean that implement Processor

class

CxfBeanDestination A CXF transport Destination that listens Camel Exchange from an associated CxfBeanEndpoint.

Uses of Processor in org.apache.camel.component.cxf.jaxrs

Classes in org.apache.camel.component.cxf.jaxrs that implement Processor

class

CxfRsProducer CxfRsProducer binds a Camel exchange to a CXF exchange, acts as a CXF JAXRS client, it will turn the normal Object invocation to a RESTful request according to resource annotation.

Methods in org.apache.camel.component.cxf.jaxrs with parameters of type Processor

Consumer

CxfRsEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.cxf.jaxrs with parameters of type Processor

CxfRsConsumer(CxfRsEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.cxf.transport

Classes in org.apache.camel.component.cxf.transport that implement Processor

protected class

CamelDestination.ConsumerProcessor

Uses of Processor in org.apache.camel.component.dataset

Methods in org.apache.camel.component.dataset that return Processor

Processor

DataSetSupport.getOutputTransformer()

Methods in org.apache.camel.component.dataset with parameters of type Processor

Consumer	DataSetEndpoint.createConsumer(Processor processor)
void	DataSetSupport.setOutputTransformer(Processor outputTransformer)
void	DataSetEndpoint.setReporter(Processor reporter) Sets a custom progress reporter

Constructors in org.apache.camel.component.dataset with parameters of type Processor

DataSetConsumer(DataSetEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.direct

Classes in org.apache.camel.component.direct that implement Processor

class

DirectProducer The direct producer.

Methods in org.apache.camel.component.direct with parameters of type Processor

Consumer

DirectEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.direct with parameters of type Processor

DirectConsumer(Endpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.dns

Methods in org.apache.camel.component.dns with parameters of type Processor

Consumer	WikipediaEndpoint.createConsumer(Processor processor)
Consumer	DnsLookupEndpoint.createConsumer(Processor processor)
Consumer	DnsIpEndpoint.createConsumer(Processor processor)
Consumer	DnsDigEndpoint.createConsumer(Processor arg0)

Uses of Processor in org.apache.camel.component.event

Methods in org.apache.camel.component.event with parameters of type Processor

EventConsumer

EventEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.event with parameters of type Processor

EventConsumer(EventEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.eventadmin

Classes in org.apache.camel.component.eventadmin that implement Processor

class

EventAdminProducer EventAdmin producer

Methods in org.apache.camel.component.eventadmin with parameters of type Processor

Consumer

EventAdminEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.eventadmin with parameters of type Processor

EventAdminConsumer(EventAdminEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.exec

Classes in org.apache.camel.component.exec that implement Processor

class

ExecProducer Exec producer.

Methods in org.apache.camel.component.exec with parameters of type Processor

Consumer

ExecEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.feed

Methods in org.apache.camel.component.feed with parameters of type Processor

Consumer	FeedEndpoint.createConsumer(Processor processor)
protected abstract FeedPollingConsumer	FeedEndpoint.createEntryPollingConsumer(FeedEndpoint feedEndpoint, Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)
protected abstract FeedPollingConsumer	FeedEndpoint.createPollingConsumer(FeedEndpoint feedEndpoint, Processor processor)

Constructors in org.apache.camel.component.feed with parameters of type Processor

FeedEntryPollingConsumer(FeedEndpoint endpoint, Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)

FeedPollingConsumer(FeedEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.file

Classes in org.apache.camel.component.file that implement Processor

class

GenericFileProducer<T> Generic file producer

Fields in org.apache.camel.component.file declared as Processor

protected Processor

GenericFileConsumer.customProcessor

Methods in org.apache.camel.component.file that return Processor

Processor

GenericFileConsumer.getCustomProcessor()

Methods in org.apache.camel.component.file with parameters of type Processor

abstract GenericFileConsumer<T>	GenericFileEndpoint.createConsumer(Processor processor)
FileConsumer	FileEndpoint.createConsumer(Processor processor)
protected void	GenericFileConsumer.customProcessExchange(Exchange exchange, Processor processor) Processes the exchange using a custom processor.
void	GenericFileConsumer.setCustomProcessor(Processor processor) Use a custom processor to process the exchange.

Constructors in org.apache.camel.component.file with parameters of type Processor

FileConsumer(GenericFileEndpoint<File> endpoint, Processor processor, GenericFileOperations<File> operations)

GenericFileConsumer(GenericFileEndpoint<T> endpoint, Processor processor, GenericFileOperations<T> operations)

Uses of Processor in org.apache.camel.component.file.remote

Classes in org.apache.camel.component.file.remote that implement Processor

class

RemoteFileProducer<T> Generic remote file producer for all the FTP variations.

Methods in org.apache.camel.component.file.remote with parameters of type Processor

protected RemoteFileConsumer<com.jcraft.jsch.ChannelSftp.LsEntry>	SftpEndpoint.buildConsumer(Processor processor)
protected abstract RemoteFileConsumer<T>	RemoteFileEndpoint.buildConsumer(Processor processor) Remote File Endpoints, impl this method to create a custom consumer specific to their "protocol" etc.
protected RemoteFileConsumer<org.apache.commons.net.ftp.FTPFile>	FtpEndpoint.buildConsumer(Processor processor)
RemoteFileConsumer<T>	RemoteFileEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.file.remote with parameters of type Processor

FtpConsumer(RemoteFileEndpoint<org.apache.commons.net.ftp.FTPFile> endpoint, Processor processor, RemoteFileOperations<org.apache.commons.net.ftp.FTPFile> fileOperations)

RemoteFileConsumer(RemoteFileEndpoint<T> endpoint, Processor processor, RemoteFileOperations<T> operations)

SftpConsumer(RemoteFileEndpoint<com.jcraft.jsch.ChannelSftp.LsEntry> endpoint, Processor processor, RemoteFileOperations<com.jcraft.jsch.ChannelSftp.LsEntry> operations)

Uses of Processor in org.apache.camel.component.flatpack

Methods in org.apache.camel.component.flatpack with parameters of type Processor

Consumer

FixedLengthEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.gae.auth

Classes in org.apache.camel.component.gae.auth that implement Processor

class

GAuthProducer

Methods in org.apache.camel.component.gae.auth with parameters of type Processor

Consumer

GAuthEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.gae.http

Classes in org.apache.camel.component.gae.http that implement Processor

class

GHttpProducer

Uses of Processor in org.apache.camel.component.gae.login

Classes in org.apache.camel.component.gae.login that implement Processor

class

GLoginProducer

Methods in org.apache.camel.component.gae.login with parameters of type Processor

Consumer

GLoginEndpoint.createConsumer(Processor processor) throws UnsupportedOperationException

Uses of Processor in org.apache.camel.component.gae.mail

Classes in org.apache.camel.component.gae.mail that implement Processor

class

GMailProducer

Methods in org.apache.camel.component.gae.mail with parameters of type Processor

Consumer

GMailEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.gae.task

Classes in org.apache.camel.component.gae.task that implement Processor

class

GTaskProducer

Uses of Processor in org.apache.camel.component.hazelcast

Methods in org.apache.camel.component.hazelcast with parameters of type Processor

abstract Consumer

HazelcastDefaultEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.hazelcast with parameters of type Processor

HazelcastDefaultConsumer(Endpoint endpoint, Processor processor, String cacheName)

Uses of Processor in org.apache.camel.component.hazelcast.atomicnumber

Classes in org.apache.camel.component.hazelcast.atomicnumber that implement Processor

class

HazelcastAtomicnumberProducer

Methods in org.apache.camel.component.hazelcast.atomicnumber with parameters of type Processor

Consumer

HazelcastAtomicnumberEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.hazelcast.instance

Methods in org.apache.camel.component.hazelcast.instance with parameters of type Processor

Consumer

HazelcastInstanceEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.hazelcast.instance with parameters of type Processor

HazelcastInstanceConsumer(DefaultEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.hazelcast.list

Classes in org.apache.camel.component.hazelcast.list that implement Processor

class

HazelcastListProducer Implementation of Hazelcast List Producer.

Methods in org.apache.camel.component.hazelcast.list with parameters of type Processor

Consumer

HazelcastListEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.hazelcast.list with parameters of type Processor

HazelcastListConsumer(Endpoint endpoint, Processor processor, String cacheName)

Uses of Processor in org.apache.camel.component.hazelcast.map

Classes in org.apache.camel.component.hazelcast.map that implement Processor

class

HazelcastMapProducer

Methods in org.apache.camel.component.hazelcast.map with parameters of type Processor

Consumer

HazelcastMapEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.hazelcast.map with parameters of type Processor

HazelcastMapConsumer(Endpoint endpoint, Processor processor, String cacheName)

Uses of Processor in org.apache.camel.component.hazelcast.multimap

Classes in org.apache.camel.component.hazelcast.multimap that implement Processor

class

HazelcastMultimapProducer

Methods in org.apache.camel.component.hazelcast.multimap with parameters of type Processor

Consumer

HazelcastMultimapEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.hazelcast.multimap with parameters of type Processor

HazelcastMultimapConsumer(Endpoint endpoint, Processor processor, String cacheName)

Uses of Processor in org.apache.camel.component.hazelcast.queue

Classes in org.apache.camel.component.hazelcast.queue that implement Processor

class

HazelcastQueueProducer

Methods in org.apache.camel.component.hazelcast.queue with parameters of type Processor

Consumer

HazelcastQueueEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.hazelcast.queue with parameters of type Processor

HazelcastQueueConsumer(Endpoint endpoint, Processor processor, String cacheName)

Uses of Processor in org.apache.camel.component.hazelcast.seda

Classes in org.apache.camel.component.hazelcast.seda that implement Processor

class

HazelcastSedaProducer Implementation of Hazelcast SEDA Producer component.

Methods in org.apache.camel.component.hazelcast.seda with parameters of type Processor

Consumer

HazelcastSedaEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.hazelcast.seda with parameters of type Processor

HazelcastSedaConsumer(Endpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.hdfs

Classes in org.apache.camel.component.hdfs that implement Processor

class

HdfsProducer

Methods in org.apache.camel.component.hdfs with parameters of type Processor

Consumer

HdfsEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.hdfs with parameters of type Processor

HdfsConsumer(DefaultEndpoint endpoint, Processor processor, HdfsConfiguration config)

Uses of Processor in org.apache.camel.component.http

Classes in org.apache.camel.component.http that implement Processor

class

HttpProducer

Constructors in org.apache.camel.component.http with parameters of type Processor

HttpConsumer(HttpEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.http4

Constructors in org.apache.camel.component.http4 with parameters of type Processor

HttpConsumer(HttpEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.ibatis

Classes in org.apache.camel.component.ibatis that implement Processor

class

IBatisProducer

Methods in org.apache.camel.component.ibatis with parameters of type Processor

IBatisConsumer

IBatisEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.ibatis with parameters of type Processor

IBatisConsumer(IBatisEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.irc

Classes in org.apache.camel.component.irc that implement Processor

class

IrcProducer

Methods in org.apache.camel.component.irc with parameters of type Processor

IrcConsumer

IrcEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.irc with parameters of type Processor

IrcConsumer(IrcEndpoint endpoint, Processor processor, org.schwering.irc.lib.IRCConnection connection)

Uses of Processor in org.apache.camel.component.javaspace

Classes in org.apache.camel.component.javaspace that implement Processor

class

JavaSpaceProducer A Producer implementation for JavaSpaces

Methods in org.apache.camel.component.javaspace with parameters of type Processor

Consumer

JavaSpaceEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.javaspace with parameters of type Processor

JavaSpaceConsumer(JavaSpaceEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.jcr

Classes in org.apache.camel.component.jcr that implement Processor

class

JcrProducer

Methods in org.apache.camel.component.jcr with parameters of type Processor

Consumer

JcrEndpoint.createConsumer(Processor processor) Currently unsupported

Uses of Processor in org.apache.camel.component.jdbc

Classes in org.apache.camel.component.jdbc that implement Processor

class

JdbcProducer

Methods in org.apache.camel.component.jdbc with parameters of type Processor

Consumer

JdbcEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.jetty

Classes in org.apache.camel.component.jetty that implement Processor

class

JettyHttpProducer

Methods in org.apache.camel.component.jetty with parameters of type Processor

Consumer

JettyHttpEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.jms

Classes in org.apache.camel.component.jms that implement Processor

class

JmsProducer

Methods in org.apache.camel.component.jms with parameters of type Processor

JmsConsumer	JmsEndpoint.createConsumer(Processor processor)
JmsConsumer	JmsEndpoint.createConsumer(Processor processor, org.springframework.jms.listener.DefaultMessageListenerContainer listenerContainer) Creates a consumer using the given processor and listener container
protected void	JmsConsumer.createMessageListener(JmsEndpoint endpoint, Processor processor)

Constructors in org.apache.camel.component.jms with parameters of type Processor

EndpointMessageListener(JmsEndpoint endpoint, Processor processor)

JmsConsumer(JmsEndpoint endpoint, Processor processor, org.springframework.jms.listener.DefaultMessageListenerContainer listenerContainer)

Uses of Processor in org.apache.camel.component.jmx

Methods in org.apache.camel.component.jmx with parameters of type Processor

Consumer

JMXEndpoint.createConsumer(Processor aProcessor)

Constructors in org.apache.camel.component.jmx with parameters of type Processor

JMXConsumer(JMXEndpoint aEndpoint, Processor aProcessor)

JMXMonitorConsumer(JMXEndpoint aEndpoint, Processor aProcessor)

Uses of Processor in org.apache.camel.component.jpa

Classes in org.apache.camel.component.jpa that implement Processor

class

JpaProducer

Methods in org.apache.camel.component.jpa with parameters of type Processor

Consumer

JpaEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.jpa with parameters of type Processor

JpaConsumer(JpaEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.jt400

Classes in org.apache.camel.component.jt400 that implement Processor

class	Jt400DataQueueProducer Producer to send data to an AS/400 data queue.
class	Jt400PgmProducer

Methods in org.apache.camel.component.jt400 with parameters of type Processor

Consumer

Jt400PgmEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.kestrel

Classes in org.apache.camel.component.kestrel that implement Processor

class

KestrelProducer Camel producer for communication with a kestrel based queue.

Methods in org.apache.camel.component.kestrel with parameters of type Processor

Consumer

KestrelEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.kestrel with parameters of type Processor

KestrelConsumer(KestrelEndpoint endpoint, Processor processor, net.spy.memcached.MemcachedClient memcachedClient)

Uses of Processor in org.apache.camel.component.language

Classes in org.apache.camel.component.language that implement Processor

class

LanguageProducer Language producer.

Methods in org.apache.camel.component.language with parameters of type Processor

Consumer

LanguageEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.ldap

Classes in org.apache.camel.component.ldap that implement Processor

class

LdapProducer

Methods in org.apache.camel.component.ldap with parameters of type Processor

Consumer

LdapEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.log

Classes in org.apache.camel.component.log that implement Processor

class

LogProducer Log producer.

Uses of Processor in org.apache.camel.component.lucene

Classes in org.apache.camel.component.lucene that implement Processor

class	LuceneIndexProducer
class	LuceneQueryProducer

Methods in org.apache.camel.component.lucene with parameters of type Processor

Consumer

LuceneEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.mail

Classes in org.apache.camel.component.mail that implement Processor

class

MailProducer A Producer to send messages using JavaMail.

Methods in org.apache.camel.component.mail with parameters of type Processor

Consumer	MailEndpoint.createConsumer(Processor processor)
Consumer	MailEndpoint.createConsumer(Processor processor, org.springframework.mail.javamail.JavaMailSenderImpl sender) Creates a consumer using the given processor and sender

Constructors in org.apache.camel.component.mail with parameters of type Processor

MailConsumer(MailEndpoint endpoint, Processor processor, org.springframework.mail.javamail.JavaMailSenderImpl sender)

Uses of Processor in org.apache.camel.component.mina

Classes in org.apache.camel.component.mina that implement Processor

class

MinaProducer A Producer implementation for MINA

Methods in org.apache.camel.component.mina with parameters of type Processor

Consumer

MinaEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.mina with parameters of type Processor

MinaConsumer(MinaEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.mock

Methods in org.apache.camel.component.mock that return Processor

Processor

MockEndpoint.getReporter()

Methods in org.apache.camel.component.mock with parameters of type Processor

Consumer	MockEndpoint.createConsumer(Processor processor)
void	MockEndpoint.setReporter(Processor reporter) Allows a processor to added to the endpoint to report on progress of the test
void	MockEndpoint.whenAnyExchangeReceived(Processor processor) Set the processor that will be invoked when the some message is received.
void	MockEndpoint.whenExchangeReceived(int index, Processor processor) Set the processor that will be invoked when the index message is received.

Uses of Processor in org.apache.camel.component.mybatis

Classes in org.apache.camel.component.mybatis that implement Processor

class

MyBatisProducer

Methods in org.apache.camel.component.mybatis with parameters of type Processor

Consumer

MyBatisEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.mybatis with parameters of type Processor

MyBatisConsumer(MyBatisEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.nagios

Classes in org.apache.camel.component.nagios that implement Processor

class

NagiosProducer

Methods in org.apache.camel.component.nagios with parameters of type Processor

Consumer

NagiosEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.netty

Classes in org.apache.camel.component.netty that implement Processor

class

NettyProducer

Methods in org.apache.camel.component.netty with parameters of type Processor

Consumer

NettyEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.netty with parameters of type Processor

NettyConsumer(NettyEndpoint nettyEndpoint, Processor processor, NettyConfiguration configuration)

Uses of Processor in org.apache.camel.component.paxlogging

Methods in org.apache.camel.component.paxlogging with parameters of type Processor

Consumer

PaxLoggingEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.paxlogging with parameters of type Processor

PaxLoggingConsumer(PaxLoggingEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.printer

Classes in org.apache.camel.component.printer that implement Processor

class

PrinterProducer

Methods in org.apache.camel.component.printer with parameters of type Processor

Consumer

PrinterEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.quartz

Methods in org.apache.camel.component.quartz with parameters of type Processor

QuartzConsumer

QuartzEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.quartz with parameters of type Processor

QuartzConsumer(QuartzEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.quickfixj

Classes in org.apache.camel.component.quickfixj that implement Processor

class

QuickfixjProducer

Methods in org.apache.camel.component.quickfixj with parameters of type Processor

Consumer

QuickfixjEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.quickfixj with parameters of type Processor

QuickfixjConsumer(Endpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.restlet

Classes in org.apache.camel.component.restlet that implement Processor

class

RestletProducer A Camel producer that acts as a client to Restlet server.

Methods in org.apache.camel.component.restlet with parameters of type Processor

Consumer

RestletEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.restlet with parameters of type Processor

RestletConsumer(Endpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.rmi

Classes in org.apache.camel.component.rmi that implement Processor

class

RmiProducer

Methods in org.apache.camel.component.rmi with parameters of type Processor

Consumer

RmiEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.rmi with parameters of type Processor

RmiConsumer(RmiEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.routebox.direct

Classes in org.apache.camel.component.routebox.direct that implement Processor

class

RouteboxDirectProducer

Methods in org.apache.camel.component.routebox.direct that return Processor

Processor

RouteboxDirectConsumer.getProcessor()

Methods in org.apache.camel.component.routebox.direct with parameters of type Processor

Consumer

RouteboxDirectEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.routebox.direct with parameters of type Processor

RouteboxDirectConsumer(RouteboxDirectEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.routebox.seda

Classes in org.apache.camel.component.routebox.seda that implement Processor

class

RouteboxSedaProducer

Methods in org.apache.camel.component.routebox.seda with parameters of type Processor

Consumer

RouteboxSedaEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.routebox.seda with parameters of type Processor

RouteboxSedaConsumer(RouteboxSedaEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.rss

Methods in org.apache.camel.component.rss with parameters of type Processor

protected FeedPollingConsumer	RssEndpoint.createEntryPollingConsumer(FeedEndpoint feedEndpoint, Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)
protected FeedPollingConsumer	RssEndpoint.createPollingConsumer(FeedEndpoint feedEndpoint, Processor processor)

Constructors in org.apache.camel.component.rss with parameters of type Processor

RssEntryPollingConsumer(RssEndpoint endpoint, Processor processor, boolean filter, Date lastUpdate, boolean throttleEntries)

RssPollingConsumer(RssEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.seda

Classes in org.apache.camel.component.seda that implement Processor

class	CollectionProducer A simple Producer which just appends to a Collection the Exchange object.
class	SedaProducer

Methods in org.apache.camel.component.seda that return Processor

Processor

SedaConsumer.getProcessor()

Methods in org.apache.camel.component.seda with parameters of type Processor

Consumer

SedaEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.seda with parameters of type Processor

SedaConsumer(SedaEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.servlet

Methods in org.apache.camel.component.servlet with parameters of type Processor

Consumer

ServletEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.shiro.security

Classes in org.apache.camel.component.shiro.security that implement Processor

class

ShiroSecurityTokenInjector

Methods in org.apache.camel.component.shiro.security that return Processor

Processor

ShiroSecurityPolicy.wrap(RouteContext routeContext, Processor processor)

Methods in org.apache.camel.component.shiro.security with parameters of type Processor

Processor

ShiroSecurityPolicy.wrap(RouteContext routeContext, Processor processor)

Uses of Processor in org.apache.camel.component.sip

Classes in org.apache.camel.component.sip that implement Processor

class

SipPublisher

Methods in org.apache.camel.component.sip with parameters of type Processor

Consumer

SipEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.sip with parameters of type Processor

SipPresenceAgent(SipEndpoint sipEndpoint, Processor processor, SipConfiguration configuration)

SipSubscriber(SipEndpoint sipEndpoint, Processor processor, SipConfiguration configuration)

Uses of Processor in org.apache.camel.component.smpp

Classes in org.apache.camel.component.smpp that implement Processor

class

SmppProducer An implementation of @{link Producer} which use the SMPP protocol

Methods in org.apache.camel.component.smpp with parameters of type Processor

Consumer

SmppEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.smpp with parameters of type Processor

MessageReceiverListenerImpl(SmppEndpoint endpoint, Processor processor, ExceptionHandler exceptionHandler)

SmppConsumer(SmppEndpoint endpoint, SmppConfiguration config, Processor processor)
The constructor which gets a smpp endpoint, a smpp configuration and a processor

Uses of Processor in org.apache.camel.component.snmp

Methods in org.apache.camel.component.snmp with parameters of type Processor

Consumer

SnmpEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.snmp with parameters of type Processor

SnmpOIDPoller(SnmpEndpoint endpoint, Processor processor)

SnmpTrapConsumer(SnmpEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.spring.integration

Classes in org.apache.camel.component.spring.integration that implement Processor

class

SpringIntegrationProducer A producer of exchanges for the Spring Integration Please specify the outputChannel in the endpoint url for this producer.

Methods in org.apache.camel.component.spring.integration with parameters of type Processor

Consumer

SpringIntegrationEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.spring.integration with parameters of type Processor

SpringIntegrationConsumer(SpringIntegrationEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.spring.integration.adapter

Classes in org.apache.camel.component.spring.integration.adapter that implement Processor

protected class

CamelSourceAdapter.ConsumerProcessor

Uses of Processor in org.apache.camel.component.spring.security

Methods in org.apache.camel.component.spring.security that return Processor

Processor

SpringSecurityAuthorizationPolicy.wrap(RouteContext routeContext, Processor processor)

Methods in org.apache.camel.component.spring.security with parameters of type Processor

Processor

SpringSecurityAuthorizationPolicy.wrap(RouteContext routeContext, Processor processor)

Uses of Processor in org.apache.camel.component.spring.ws

Classes in org.apache.camel.component.spring.ws that implement Processor

class

SpringWebserviceProducer

Methods in org.apache.camel.component.spring.ws with parameters of type Processor

Consumer

SpringWebserviceEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.spring.ws with parameters of type Processor

SpringWebserviceConsumer(Endpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.sql

Classes in org.apache.camel.component.sql that implement Processor

class

SqlProducer

Methods in org.apache.camel.component.sql with parameters of type Processor

Consumer

SqlEndpoint.createConsumer(Processor processor)

Uses of Processor in org.apache.camel.component.stream

Classes in org.apache.camel.component.stream that implement Processor

class

StreamProducer Producer that can write to streams

Methods in org.apache.camel.component.stream with parameters of type Processor

Consumer

StreamEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.stream with parameters of type Processor

StreamConsumer(StreamEndpoint endpoint, Processor processor, String uri)

Uses of Processor in org.apache.camel.component.stringtemplate

Constructors in org.apache.camel.component.stringtemplate with parameters of type Processor

StringTemplateEndpoint(String endpointUri, Processor processor, String resourceUri)

Uses of Processor in org.apache.camel.component.timer

Methods in org.apache.camel.component.timer with parameters of type Processor

Consumer

TimerEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.timer with parameters of type Processor

TimerConsumer(TimerEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.validator

Classes in org.apache.camel.component.validator that implement Processor

class

SpringValidator Validator that uses Spring for reading the scheme resource.

Uses of Processor in org.apache.camel.component.validator.jing

Classes in org.apache.camel.component.validator.jing that implement Processor

class

JingValidator A validator which uses the Jing library to validate XML against RelaxNG

Uses of Processor in org.apache.camel.component.xmpp

Classes in org.apache.camel.component.xmpp that implement Processor

class	XmppGroupChatProducer
class	XmppPrivateChatProducer

Methods in org.apache.camel.component.xmpp with parameters of type Processor

Consumer

XmppEndpoint.createConsumer(Processor processor)

Constructors in org.apache.camel.component.xmpp with parameters of type Processor

XmppConsumer(XmppEndpoint endpoint, Processor processor)

Uses of Processor in org.apache.camel.component.xquery

Classes in org.apache.camel.component.xquery that implement Processor

class

XQueryBuilder Creates an XQuery builder.

Uses of Processor in org.apache.camel.converter

Methods in org.apache.camel.converter that return Processor

Processor	CamelConverter.toProcessor(Expression expresion)
Processor	CamelConverter.toProcessor(Predicate predicate)

Uses of Processor in org.apache.camel.core.osgi

Methods in org.apache.camel.core.osgi with parameters of type Processor

void	OsgiServiceRegistry.onErrorHandlerAdd(RouteContext routeContext, Processor processor, ErrorHandlerBuilder errorHandlerBuilder)

Uses of Processor in org.apache.camel.example.gae

Classes in org.apache.camel.example.gae that implement Processor

class	ReportGenerator
class	RequestProcessor
class	ResponseProcessor

Uses of Processor in org.apache.camel.example.gauth

Classes in org.apache.camel.example.gauth that implement Processor

class

TutorialTokenProcessor Reads an OAuth access token plus access token secret from a Camel message and stores them in cookies.

Uses of Processor in org.apache.camel.example.service

Classes in org.apache.camel.example.service that implement Processor

class

Reporting

Uses of Processor in org.apache.camel.fabric

Classes in org.apache.camel.fabric that implement Processor

class

FabricTraceProcessor

Methods in org.apache.camel.fabric that return Processor

Processor

FabricTracer.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget)

Methods in org.apache.camel.fabric with parameters of type Processor

Processor

FabricTracer.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget)

Constructors in org.apache.camel.fabric with parameters of type Processor

FabricTraceProcessor(Queue<FabricTracerEventMessage> queue, Processor processor, ProcessorDefinition<?> processorDefinition, FabricTracer tracer)

Uses of Processor in org.apache.camel.impl

Classes in org.apache.camel.impl that implement Processor

class	DefaultAsyncProducer A default implementation of Producer for implementation inheritance, which can process Exchanges asynchronously.
class	DefaultProducer A default implementation of Producer for implementation inheritance.
class	EventDrivenPollingConsumer A default implementation of the PollingConsumer which uses the normal asynchronous consumer mechanism along with a BlockingQueue to allow the caller to pull messages on demand.
class	SynchronousDelegateProducer To process the delegated producer in synchronous mode.

Methods in org.apache.camel.impl that return Processor

protected Processor	DefaultProducerTemplate.createBodyAndHeaderProcessor(Object body, String header, Object headerValue)
protected Processor	DefaultProducerTemplate.createBodyAndPropertyProcessor(Object body, String property, Object propertyValue)
protected Processor	CamelPostProcessorHelper.createConsumerProcessor(Object pojo, Method method, Endpoint endpoint) Create a processor which invokes the given method when an incoming message exchange is received
protected Processor	ProcessorEndpoint.createProcessor()
Processor	DefaultRouteContext.createProcessor(ProcessorDefinition<?> node)
protected Processor	DefaultProducerTemplate.createSetBodyProcessor(Object body)
Processor	ProcessorEndpoint.getProcessor()
Processor	OnExceptionRouteNode.getProcessor()
Processor	OnCompletionRouteNode.getProcessor()
Processor	EventDrivenConsumerRoute.getProcessor()
Processor	DoFinallyRouteNode.getProcessor()
Processor	DoCatchRouteNode.getProcessor()
Processor	DefaultRouteNode.getProcessor()
Processor	DefaultConsumer.getProcessor()
Processor	AggregateRouteNode.getProcessor()

Methods in org.apache.camel.impl that return types with arguments of type Processor

Navigate<Processor>

EventDrivenConsumerRoute.navigate()

Methods in org.apache.camel.impl with parameters of type Processor

void	DefaultRouteContext.addEventDrivenProcessor(Processor processor)
boolean	DefaultDebugger.afterProcess(Exchange exchange, Processor processor, ProcessorDefinition definition, long timeTaken)
void	BreakpointSupport.afterProcess(Exchange exchange, Processor processor, ProcessorDefinition definition, long timeTaken)
void	MDCUnitOfWork.afterProcess(Processor processor, Exchange exchange, AsyncCallback callback, boolean doneSync)
void	DefaultUnitOfWork.afterProcess(Processor processor, Exchange exchange, AsyncCallback callback, boolean doneSync)
Future<Exchange>	DefaultProducerTemplate.asyncCallback(Endpoint endpoint, Processor processor, Synchronization onCompletion)
Future<Exchange>	DefaultProducerTemplate.asyncCallback(String uri, Processor processor, Synchronization onCompletion)
Future<Exchange>	DefaultProducerTemplate.asyncSend(Endpoint endpoint, Processor processor)
Future<Exchange>	DefaultProducerTemplate.asyncSend(String uri, Processor processor)
boolean	DefaultDebugger.beforeProcess(Exchange exchange, Processor processor, ProcessorDefinition definition)
void	BreakpointSupport.beforeProcess(Exchange exchange, Processor processor, ProcessorDefinition definition)
AsyncCallback	MDCUnitOfWork.beforeProcess(Processor processor, Exchange exchange, AsyncCallback callback)
AsyncCallback	DefaultUnitOfWork.beforeProcess(Processor processor, Exchange exchange, AsyncCallback callback)
Consumer	InterceptSendToEndpoint.createConsumer(Processor processor)
Consumer	DefaultPollingEndpoint.createConsumer(Processor processor)
boolean	ConditionSupport.matchProcess(Exchange exchange, Processor processor, ProcessorDefinition definition)
protected void	DefaultDebugger.onAfterProcess(Exchange exchange, Processor processor, ProcessorDefinition definition, long timeTaken, Breakpoint breakpoint)
protected void	DefaultDebugger.onBeforeProcess(Exchange exchange, Processor processor, ProcessorDefinition definition, Breakpoint breakpoint)
Exchange	DefaultProducerTemplate.request(Endpoint endpoint, Processor processor)
Exchange	DefaultProducerTemplate.request(String endpoint, Processor processor)
Exchange	ProducerCache.send(Endpoint endpoint, ExchangePattern pattern, Processor processor) Sends an exchange to an endpoint using a supplied Processor to populate the exchange
Exchange	DefaultProducerTemplate.send(Endpoint endpoint, ExchangePattern pattern, Processor processor)
Exchange	ProducerCache.send(Endpoint endpoint, Processor processor) Sends an exchange to an endpoint using a supplied Processor to populate the exchange
Exchange	DefaultProducerTemplate.send(Endpoint endpoint, Processor processor)
Exchange	DefaultProducerTemplate.send(Processor processor)
Exchange	DefaultProducerTemplate.send(String endpointUri, ExchangePattern pattern, Processor processor)
Exchange	DefaultProducerTemplate.send(String endpointUri, Processor processor)
protected Exchange	ProducerCache.sendExchange(Endpoint endpoint, ExchangePattern pattern, Processor processor, Exchange exchange)
void	InterceptSendToEndpoint.setDetour(Processor detour)
void	ProcessorEndpoint.setProcessor(Processor processor)

Constructors in org.apache.camel.impl with parameters of type Processor

DefaultConsumer(Endpoint endpoint, Processor processor)

DefaultRouteNode(ProcessorDefinition<?> processorDefinition, Processor processor)

DefaultScheduledPollConsumer(DefaultEndpoint defaultEndpoint, Processor processor)

DefaultScheduledPollConsumer(Endpoint endpoint, Processor processor, ScheduledExecutorService executor)

EventDrivenConsumerRoute(RouteContext routeContext, Endpoint endpoint, Processor processor)

ProcessorEndpoint(String endpointUri, CamelContext context, Processor processor)

ProcessorEndpoint(String endpointUri, Component component, Processor processor)

ProcessorEndpoint(String endpointUri, Processor processor)

ProcessorPollingConsumer(Endpoint endpoint, Processor processor)

ScheduledPollConsumer(Endpoint endpoint, Processor processor)

ScheduledPollConsumer(Endpoint endpoint, Processor processor, ScheduledExecutorService executor)

Uses of Processor in org.apache.camel.impl.converter

Methods in org.apache.camel.impl.converter with parameters of type Processor

static AsyncProcessor

AsyncProcessorTypeConverter.convert(Processor value)

Uses of Processor in org.apache.camel.loanbroker.queue.version

Classes in org.apache.camel.loanbroker.queue.version that implement Processor

class	Bank
class	CreditAgency
class	Translator

Uses of Processor in org.apache.camel.management

Classes in org.apache.camel.management that implement Processor

class

InstrumentationProcessor JMX enabled processor that uses the ManagedCounter for instrumenting processing of exchanges.

Methods in org.apache.camel.management that return Processor

Processor

InstrumentationInterceptStrategy.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition definition, Processor target, Processor nextTarget)

Methods in org.apache.camel.management with parameters of type Processor

EventObject	DefaultEventFactory.createExchangeFailureHandledEvent(Exchange exchange, Processor failureHandler, boolean deadLetterChannel)
Object	DefaultManagementObjectStrategy.getManagedObjectForErrorHandler(CamelContext context, RouteContext routeContext, Processor errorHandler, ErrorHandlerBuilder errorHandlerBuilder)
Object	DefaultManagementObjectStrategy.getManagedObjectForProcessor(CamelContext context, Processor processor, ProcessorDefinition definition, Route route)
ObjectName	DefaultManagementNamingStrategy.getObjectNameForErrorHandler(RouteContext routeContext, Processor errorHandler, ErrorHandlerBuilder builder)
ObjectName	DefaultManagementNamingStrategy.getObjectNameForProcessor(CamelContext context, Processor processor, ProcessorDefinition<?> definition)
void	DefaultManagementLifecycleStrategy.onErrorHandlerAdd(RouteContext routeContext, Processor errorHandler, ErrorHandlerBuilder errorHandlerBuilder)
Processor	InstrumentationInterceptStrategy.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition definition, Processor target, Processor nextTarget)

Constructor parameters in org.apache.camel.management with type arguments of type Processor

InstrumentationInterceptStrategy(Map<ProcessorDefinition,PerformanceCounter> registeredCounters, Map<Processor,KeyValueHolder<ProcessorDefinition,InstrumentationProcessor>> wrappedProcessors)

Uses of Processor in org.apache.camel.management.event

Methods in org.apache.camel.management.event that return Processor

Processor

ExchangeFailureHandledEvent.getFailureHandler()

Constructors in org.apache.camel.management.event with parameters of type Processor

ExchangeFailureHandledEvent(Exchange source, Processor failureHandler, boolean deadLetterChannel)

Uses of Processor in org.apache.camel.management.mbean

Methods in org.apache.camel.management.mbean that return Processor

Processor	ManagedErrorHandler.getErrorHandler()
Processor	ManagedProcessor.getProcessor()

Constructors in org.apache.camel.management.mbean with parameters of type Processor

ManagedErrorHandler(RouteContext routeContext, Processor errorHandler, ErrorHandlerBuilder builder)

ManagedProcessor(CamelContext context, Processor processor, ProcessorDefinition<?> definition)

Uses of Processor in org.apache.camel.model

Classes in org.apache.camel.model that implement Processor

class

LoadBalancerDefinition Represents an XML <loadBalancer/> element

Fields in org.apache.camel.model declared as Processor

protected Processor

InterceptDefinition.output

Fields in org.apache.camel.model with type parameters of type Processor

protected List<Processor>

InterceptDefinition.intercepted

Methods in org.apache.camel.model that return Processor

Processor	ProcessorDefinition.createChildProcessor(RouteContext routeContext, boolean mandatory) Creates the child processor (outputs) from the current definition
protected Processor	ProcessorDefinition.createCompositeProcessor(RouteContext routeContext, List<Processor> list) Creates a new instance of some kind of composite processor which defaults to using a Pipeline but derived classes could change the behaviour
protected Processor	MulticastDefinition.createCompositeProcessor(RouteContext routeContext, List<Processor> list)
Processor	ProcessorDefinition.createOutputsProcessor(RouteContext routeContext) Prefer to use {#link #createChildProcessor}.
protected Processor	ProcessorDefinition.createOutputsProcessor(RouteContext routeContext, Collection<ProcessorDefinition> outputs)
protected Processor	LoadBalanceDefinition.createOutputsProcessor(RouteContext routeContext, Collection<ProcessorDefinition> outputs)
Processor	WireTapDefinition.createProcessor(RouteContext routeContext)
Processor	UnmarshalDefinition.createProcessor(RouteContext routeContext)
Processor	TryDefinition.createProcessor(RouteContext routeContext)
Processor	TransformDefinition.createProcessor(RouteContext routeContext)
Processor	TransactedDefinition.createProcessor(RouteContext routeContext)
Processor	ThrowExceptionDefinition.createProcessor(RouteContext routeContext)
Processor	ThrottleDefinition.createProcessor(RouteContext routeContext)
Processor	ThreadsDefinition.createProcessor(RouteContext routeContext)
Processor	StopDefinition.createProcessor(RouteContext routeContext)
Processor	SplitDefinition.createProcessor(RouteContext routeContext)
Processor	SortDefinition.createProcessor(RouteContext routeContext)
Processor	SetPropertyDefinition.createProcessor(RouteContext routeContext)
Processor	SetOutHeaderDefinition.createProcessor(RouteContext routeContext) Deprecated.
Processor	SetHeaderDefinition.createProcessor(RouteContext routeContext)
Processor	SetFaultBodyDefinition.createProcessor(RouteContext routeContext)
Processor	SetExchangePatternDefinition.createProcessor(RouteContext routeContext)
Processor	SetBodyDefinition.createProcessor(RouteContext routeContext)
Processor	SendDefinition.createProcessor(RouteContext routeContext)
Processor	SamplingDefinition.createProcessor(RouteContext routeContext)
Processor	RoutingSlipDefinition.createProcessor(RouteContext routeContext)
Processor	RollbackDefinition.createProcessor(RouteContext routeContext)
Processor	ResequenceDefinition.createProcessor(RouteContext routeContext)
Processor	RemovePropertyDefinition.createProcessor(RouteContext routeContext)
Processor	RemoveHeadersDefinition.createProcessor(RouteContext routeContext)
Processor	RemoveHeaderDefinition.createProcessor(RouteContext routeContext)
Processor	RecipientListDefinition.createProcessor(RouteContext routeContext)
Processor	ProcessorDefinition.createProcessor(RouteContext routeContext) Override this in definition class and implement logic to create the processor based on the definition model.
Processor	ProcessDefinition.createProcessor(RouteContext routeContext)
Processor	PollEnrichDefinition.createProcessor(RouteContext routeContext)
Processor	PolicyDefinition.createProcessor(RouteContext routeContext)
Processor	PipelineDefinition.createProcessor(RouteContext routeContext)
Processor	OtherwiseDefinition.createProcessor(RouteContext routeContext)
Processor	OnCompletionDefinition.createProcessor(RouteContext routeContext)
Processor	MulticastDefinition.createProcessor(RouteContext routeContext)
Processor	MarshalDefinition.createProcessor(RouteContext routeContext)
Processor	LoopDefinition.createProcessor(RouteContext routeContext)
Processor	LogDefinition.createProcessor(RouteContext routeContext)
Processor	LoadBalanceDefinition.createProcessor(RouteContext routeContext)
Processor	InterceptSendToEndpointDefinition.createProcessor(RouteContext routeContext)
Processor	InterceptFromDefinition.createProcessor(RouteContext routeContext)
Processor	InterceptDefinition.createProcessor(RouteContext routeContext)
Processor	IdempotentConsumerDefinition.createProcessor(RouteContext routeContext)
Processor	FinallyDefinition.createProcessor(RouteContext routeContext)
Processor	EnrichDefinition.createProcessor(RouteContext routeContext)
Processor	DynamicRouterDefinition.createProcessor(RouteContext routeContext)
Processor	DelayDefinition.createProcessor(RouteContext routeContext)
Processor	ConvertBodyDefinition.createProcessor(RouteContext routeContext)
Processor	ChoiceDefinition.createProcessor(RouteContext routeContext)
Processor	BeanDefinition.createProcessor(RouteContext routeContext)
Processor	AggregateDefinition.createProcessor(RouteContext routeContext)
Processor	AOPDefinition.createProcessor(RouteContext routeContext) Deprecated.
Processor	OnExceptionDefinition.getErrorHandler()
Processor	InterceptDefinition.getInterceptedProcessor(int index)
Processor	WireTapDefinition.getNewExchangeProcessor()
Processor	WireTapDefinition.getOnPrepare()
Processor	SplitDefinition.getOnPrepare()
Processor	RecipientListDefinition.getOnPrepare()
Processor	MulticastDefinition.getOnPrepare()
Processor	OnExceptionDefinition.getOnRedelivery()
protected Processor	ProcessorDefinition.makeProcessor(RouteContext routeContext) Creates the processor and wraps it in any necessary interceptors and error handlers
protected Processor	ProcessorDefinition.wrapChannel(RouteContext routeContext, Processor processor, ProcessorDefinition child)
protected Processor	ProcessorDefinition.wrapInErrorHandler(RouteContext routeContext, ErrorHandlerBuilder builder, Processor output) Wraps the given output in an error handler
Processor	ProcessorDefinition.wrapProcessor(RouteContext routeContext, Processor processor) Wraps the child processor in whatever necessary interceptors and error handlers

Methods in org.apache.camel.model that return types with arguments of type Processor

List<Processor>

LoadBalancerDefinition.getProcessors()

Methods in org.apache.camel.model with parameters of type Processor

void	LoadBalancerDefinition.addProcessor(Processor processor)
WireTapDefinition<Type>	WireTapDefinition.newExchange(Processor processor) Sends a new Exchange, instead of tapping an existing, using ExchangePattern.InOnly
WireTapDefinition<Type>	WireTapDefinition.onPrepare(Processor onPrepare) Uses the Processor when preparing the Exchange to be send.
SplitDefinition	SplitDefinition.onPrepare(Processor onPrepare) Uses the Processor when preparing the Exchange to be send.
RecipientListDefinition<Type>	RecipientListDefinition.onPrepare(Processor onPrepare) Uses the Processor when preparing the Exchange to be used send.
MulticastDefinition	MulticastDefinition.onPrepare(Processor onPrepare) Uses the Processor when preparing the Exchange to be send.
OnExceptionDefinition	OnExceptionDefinition.onRedelivery(Processor processor) Sets a processor that should be processed before a redelivery attempt.
Type	ProcessorDefinition.process(Processor processor) Message Translator EIP: Adds the custom processor to this destination which could be a final destination, or could be a transformation in a pipeline
void	LoadBalancerDefinition.removeProcessor(Processor processor)
void	WireTapDefinition.setNewExchangeProcessor(Processor processor)
void	WireTapDefinition.setOnPrepare(Processor onPrepare)
void	SplitDefinition.setOnPrepare(Processor onPrepare)
void	RecipientListDefinition.setOnPrepare(Processor onPrepare)
void	MulticastDefinition.setOnPrepare(Processor onPrepare)
void	OnExceptionDefinition.setOnRedelivery(Processor onRedelivery)
WireTapDefinition<Type>	ProcessorDefinition.wireTap(String uri, boolean copy, Processor processor) Deprecated. use the fluent builder from WireTapDefinition, will be removed in Camel 3.0
WireTapDefinition<Type>	ProcessorDefinition.wireTap(String uri, Processor processor) Deprecated. use the fluent builder from WireTapDefinition, will be removed in Camel 3.0
protected Processor	ProcessorDefinition.wrapChannel(RouteContext routeContext, Processor processor, ProcessorDefinition child)
protected Processor	ProcessorDefinition.wrapInErrorHandler(RouteContext routeContext, ErrorHandlerBuilder builder, Processor output) Wraps the given output in an error handler
Processor	ProcessorDefinition.wrapProcessor(RouteContext routeContext, Processor processor) Wraps the child processor in whatever necessary interceptors and error handlers

Method parameters in org.apache.camel.model with type arguments of type Processor

protected Processor	ProcessorDefinition.createCompositeProcessor(RouteContext routeContext, List<Processor> list) Creates a new instance of some kind of composite processor which defaults to using a Pipeline but derived classes could change the behaviour
protected Processor	MulticastDefinition.createCompositeProcessor(RouteContext routeContext, List<Processor> list)

Constructors in org.apache.camel.model with parameters of type Processor

ProcessDefinition(Processor processor)

Uses of Processor in org.apache.camel.model.loadbalancer

Classes in org.apache.camel.model.loadbalancer that implement Processor

class	CustomLoadBalancerDefinition Represents an XML <customLoadBalancer/> element
class	FailoverLoadBalancerDefinition Represents an XML <failover/> element
class	RandomLoadBalancerDefinition Represents an XML <random/> element
class	RoundRobinLoadBalancerDefinition Represents an XML <roundRobin/> element
class	StickyLoadBalancerDefinition Represents an XML <sticky/> element
class	TopicLoadBalancerDefinition Represents an XML <topic/> element
class	WeightedLoadBalancerDefinition Represents an XML <weighted/> element

Uses of Processor in org.apache.camel.processor

Subinterfaces of Processor in org.apache.camel.processor

interface

ErrorHandler An interface used to represent an error handler

Classes in org.apache.camel.processor that implement Processor

class	AOPProcessor
class	BatchProcessor Deprecated. may be removed in the future when we overhaul the resequencer EIP
class	CamelLogger A Processor which just logs to a CamelLogger object which can be used as an exception handler instead of using a dead letter queue.
class	CatchProcessor A processor which catches exceptions.
class	ChildUnitOfWorkProcessor An UnitOfWorkProcessor that creates a child UnitOfWork that is associated to a parent UnitOfWork.
class	ChoiceProcessor Implements a Choice structure where one or more predicates are used which if they are true their processors are used, with a default otherwise clause used if none match.
class	ConvertBodyProcessor A processor which converts the payload of the input message to be of the given type If the convertions fails an InvalidPayloadException is thrown.
class	DeadLetterChannel Implements a Dead Letter Channel after attempting to redeliver the message using the RedeliveryPolicy
class	DefaultChannel DefaultChannel is the default Channel.
class	DefaultErrorHandler Default error handler
class	Delayer A Delayer which delays processing the exchange until the correct amount of time has elapsed using an expression to determine the delivery time.
class	DelayProcessorSupport A useful base class for any processor which provides some kind of throttling or delayed processing.
class	DelegateAsyncProcessor A Delegate pattern which delegates processing to a nested AsyncProcessor which can be useful for implementation inheritance when writing an Policy Important: This implementation does support the asynchronous routing engine.
class	DelegateProcessor A Delegate pattern which delegates processing to a nested Processor which can be useful for implementation inheritance when writing an Policy Important: This implementation does not support the asynchronous routing engine.
class	DynamicRouter Implements a Dynamic Router pattern where the destination(s) is computed at runtime.
class	Enricher A content enricher that enriches input data by first obtaining additional data from a resource represented by an endpoint producer and second by aggregating input data and additional data.
class	ErrorHandlerSupport Support class for ErrorHandler implementations.
class	EvaluateExpressionProcessor A Processor which evaluates an Expression and stores the result as a property on the Exchange with the key Exchange.EVALUATE_EXPRESSION_RESULT.
class	ExchangePatternProcessor
class	FatalFallbackErrorHandler An ErrorHandler used as a safe fallback when processing by other error handlers such as the OnExceptionDefinition.
class	FilterProcessor The processor which implements the Message Filter EIP pattern.
class	InterceptEndpointProcessor Endpoint intercept processor so we know the processor is supposed to intercept an endpoint.
class	InterceptorToAsyncProcessorBridge A bridge to have regular interceptors implemented as Processor work with the asynchronous routing engine without causing side effects.
class	LoggingErrorHandler An ErrorHandler which uses commons-logging to dump the error
class	LogProcessor A processor which evaluates an Expression and logs it.
class	LoopProcessor The processor which sends messages in a loop.
class	MarshalProcessor Marshals the body of the incoming message using the given data format
class	MulticastProcessor Implements the Multicast pattern to send a message exchange to a number of endpoints, each endpoint receiving a copy of the message exchange.
class	OnCompletionProcessor
class	Pipeline Creates a Pipeline pattern where the output of the previous step is sent as input to the next step, reusing the same message exchanges
class	PollEnricher A content enricher that enriches input data by first obtaining additional data from a resource represented by an endpoint producer and second by aggregating input data and additional data.
class	RecipientList Implements a dynamic Recipient List pattern where the list of actual endpoints to send a message exchange to are dependent on some dynamic expression.
class	RecipientListProcessor Implements a dynamic Recipient List pattern where the list of actual endpoints to send a message exchange to are dependent on some dynamic expression.
class	RedeliveryErrorHandler Base redeliverable error handler that also supports a final dead letter queue in case all redelivery attempts fail.
class	Resequencer An implementation of the Resequencer which can reorder messages within a batch.
class	RollbackProcessor Processor for marking an Exchange to rollback.
class	RoutePolicyProcessor Processor which instruments the RoutePolicy.
class	RoutingSlip Implements a Routing Slip pattern where the list of actual endpoints to send a message exchange to are dependent on the value of a message header.
class	SamplingThrottler A SamplingThrottler is a special kind of throttler.
class	SendProcessor Processor for forwarding exchanges to an endpoint destination.
class	SetBodyProcessor A processor which sets the body on the IN message with an expression
class	SortProcessor A processor that sorts the expression using a comparator
class	Splitter Implements a dynamic Splitter pattern where an expression is evaluated to iterate through each of the parts of a message and then each part is then send to some endpoint.
class	StopProcessor Stops continue processing the route and marks it as complete.
class	StreamResequencer A resequencer that re-orders a (continuous) stream of Exchanges.
class	SubUnitOfWorkProcessor A processor that processes the processor in a SubUnitOfWork context.
class	ThreadsProcessor Threads processor that leverage a thread pool for continue processing the Exchanges using the asynchronous routing engine.
class	Throttler A Throttler will set a limit on the maximum number of message exchanges which can be sent to a processor within a specific time period.
class	ThroughputLogger A logger for logging message throughput.
class	ThrowExceptionProcessor The processor which implements the ThrowException DSL
class	TransformProcessor A processor which sets the body on the OUT message with an expression
class	TryProcessor Implements try/catch/finally type processing
class	UnitOfWorkProcessor Ensures the Exchange is routed under the boundaries of an UnitOfWork.
class	UnitOfWorkProducer Ensures a Producer is executed within an UnitOfWork.
class	UnmarshalProcessor Unmarshals the body of the incoming message using the given data format
class	WireTapProcessor Processor for wire tapping exchanges to an endpoint destination.
class	WrapProcessor A processor which ensures wrapping processors is having lifecycle handled.

Fields in org.apache.camel.processor declared as Processor

protected Processor	RedeliveryErrorHandler.deadLetter
protected Processor	MulticastProcessor.onPrepare
protected Processor	RedeliveryErrorHandler.output
protected Processor	DelegateProcessor.processor
protected Processor	RedeliveryErrorHandler.redeliveryProcessor

Methods in org.apache.camel.processor that return Processor

protected Processor	MulticastProcessor.createErrorHandler(RouteContext routeContext, Exchange exchange, Processor processor)
Processor	RedeliveryErrorHandler.getDeadLetter() Returns the dead letter that message exchanges will be sent to if the redelivery attempts fail
Processor	DefaultChannel.getErrorHandler()
Processor	DefaultChannel.getNextProcessor()
Processor	WireTapProcessor.getOnPrepare()
Processor	RecipientList.getOnPrepare()
Processor	ChoiceProcessor.getOtherwise()
Processor	RedeliveryErrorHandler.getOutput() Returns the output processor
abstract Processor	ErrorHandlerSupport.getOutput() Gets the output
Processor	DefaultChannel.getOutput()
Processor	StreamResequencer.getProcessor() Returns the next processor.
Processor	ProcessorExchangePair.getProcessor()
Processor	DelegateProcessor.getProcessor()
Processor	BatchProcessor.getProcessor() Deprecated.
static Processor	Pipeline.newInstance(CamelContext camelContext, List<Processor> processors)

Methods in org.apache.camel.processor that return types with arguments of type Processor

List<Processor>	WireTapProcessor.getNewExchangeProcessors()
Collection<Processor>	MulticastProcessor.getProcessors() Returns the producers to multicast to
List<Processor>	TryProcessor.next()
List<Processor>	StreamResequencer.next()
List<Processor>	MulticastProcessor.next()
List<Processor>	DelegateProcessor.next()
List<Processor>	DelegateAsyncProcessor.next()
List<Processor>	DefaultChannel.next()
List<Processor>	ChoiceProcessor.next()
List<Processor>	BatchProcessor.next() Deprecated.

Methods in org.apache.camel.processor with parameters of type Processor

void	WireTapProcessor.addNewExchangeProcessor(Processor processor)
protected Processor	MulticastProcessor.createErrorHandler(RouteContext routeContext, Exchange exchange, Processor processor)
protected ProcessorExchangePair	MulticastProcessor.createProcessorExchangePair(int index, Processor processor, Exchange exchange, RouteContext routeContext) Creates the ProcessorExchangePair which holds the processor and exchange to be send out.
protected UnitOfWorkProcessor	MulticastProcessor.createUnitOfWorkProcessor(Processor processor, Exchange exchange) Strategy to create the UnitOfWorkProcessor to be used for the sub route
protected boolean	RedeliveryErrorHandler.deliverToFailureProcessor(Processor processor, Exchange exchange, RedeliveryErrorHandler.RedeliveryData data, AsyncCallback callback) All redelivery attempts failed so move the exchange to the dead letter queue
protected static void	OnCompletionProcessor.doProcess(Processor processor, Exchange exchange) Processes the exchange by the processors
void	DefaultChannel.setErrorHandler(Processor errorHandler)
void	DefaultChannel.setNextProcessor(Processor next)
void	WireTapProcessor.setOnPrepare(Processor onPrepare)
void	RecipientList.setOnPrepare(Processor onPrepare)
void	DefaultChannel.setOutput(Processor output)
void	DelegateProcessor.setProcessor(Processor processor)
void	DelegateAsyncProcessor.setProcessor(Processor processor)
void	InterceptorToAsyncProcessorBridge.setTarget(Processor target)
protected static void	MulticastProcessor.setToEndpoint(Exchange exchange, Processor processor)

Method parameters in org.apache.camel.processor with type arguments of type Processor

protected boolean	Pipeline.continueRouting(Iterator<Processor> it, Exchange exchange)
static Processor	Pipeline.newInstance(CamelContext camelContext, List<Processor> processors)
void	WireTapProcessor.setNewExchangeProcessors(List<Processor> newExchangeProcessors)

Constructors in org.apache.camel.processor with parameters of type Processor

AOPProcessor(Processor tryProcessor, List<CatchProcessor> catchClauses, Processor finallyProcessor)

BatchProcessor(CamelContext camelContext, Processor processor, Collection<Exchange> collection)
Deprecated.

CatchProcessor(List<Class> exceptions, Processor processor, Predicate onWhen, Predicate handled)

ChildUnitOfWorkProcessor(UnitOfWork parent, Processor processor)

ChildUnitOfWorkProcessor(UnitOfWork parent, RouteContext routeContext, Processor processor)

ChoiceProcessor(List<FilterProcessor> filters, Processor otherwise)

DeadLetterChannel(CamelContext camelContext, Processor output, CamelLogger logger, Processor redeliveryProcessor, RedeliveryPolicy redeliveryPolicy, ExceptionPolicyStrategy exceptionPolicyStrategy, Processor deadLetter, String deadLetterUri, boolean useOriginalBodyPolicy, Predicate retryWhile, String executorServiceRef)
Creates the dead letter channel.

DefaultErrorHandler(CamelContext camelContext, Processor output, CamelLogger logger, Processor redeliveryProcessor, RedeliveryPolicy redeliveryPolicy, ExceptionPolicyStrategy exceptionPolicyStrategy, Predicate retryWhile, String executorServiceRef)
Creates the default error handler.

Delayer(Processor processor, Expression delay, ScheduledExecutorService executorService)

DelayProcessorSupport(Processor processor)

DelayProcessorSupport(Processor processor, ScheduledExecutorService executorService)

DelegateAsyncProcessor(Processor processor)

DelegateProcessor(Processor processor)

FatalFallbackErrorHandler(Processor processor)

FilterProcessor(Predicate predicate, Processor processor)

InterceptEndpointProcessor(String uri, Processor processor)

InterceptorToAsyncProcessorBridge(Processor interceptor)
Constructs the bridge

InterceptorToAsyncProcessorBridge(Processor interceptor, AsyncProcessor target)
Constructs the bridge

LoggingErrorHandler(CamelContext camelContext, Processor output, CamelLogger logger, ExceptionPolicyStrategy exceptionPolicyStrategy)
Creates the logging error handler.

LoopProcessor(Processor processor, Expression expression, boolean copy)

MulticastProcessor(CamelContext camelContext, Collection<Processor> processors, AggregationStrategy aggregationStrategy, boolean parallelProcessing, ExecutorService executorService, boolean streaming, boolean stopOnException, long timeout, Processor onPrepare, boolean shareUnitOfWork)

OnCompletionProcessor(CamelContext camelContext, Processor processor, ExecutorService executorService, boolean onCompleteOnly, boolean onFailureOnly, Predicate onWhen, boolean useOriginalBody)

RecipientListProcessor(CamelContext camelContext, ProducerCache producerCache, Iterator<Object> iter, AggregationStrategy aggregationStrategy, boolean parallelProcessing, ExecutorService executorService, boolean streaming, boolean stopOnException, long timeout, Processor onPrepare, boolean shareUnitOfWork)

RedeliveryErrorHandler(CamelContext camelContext, Processor output, CamelLogger logger, Processor redeliveryProcessor, RedeliveryPolicy redeliveryPolicy, Processor deadLetter, String deadLetterUri, boolean useOriginalMessagePolicy, Predicate retryWhile, String executorServiceRef)

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)

RoutePolicyProcessor(Processor processor, List<RoutePolicy> routePolicies)

SamplingThrottler(Processor processor, long messageFrequency)

SamplingThrottler(Processor processor, long samplePeriod, TimeUnit units)

Splitter(CamelContext camelContext, Expression expression, Processor destination, AggregationStrategy aggregationStrategy)

Splitter(CamelContext camelContext, Expression expression, Processor destination, AggregationStrategy aggregationStrategy, boolean parallelProcessing, ExecutorService executorService, boolean streaming, boolean stopOnException, long timeout, Processor onPrepare, boolean useSubUnitOfWork)

StreamResequencer(CamelContext camelContext, Processor processor, SequenceElementComparator<Exchange> comparator)
Creates a new StreamResequencer instance.

SubUnitOfWorkProcessor(Processor processor)

SubUnitOfWorkProcessor(RouteContext routeContext, Processor processor)

Throttler(Processor processor, Expression maxRequestsPerPeriodExpression, long timePeriodMillis, ScheduledExecutorService executorService)

TryProcessor(Processor tryProcessor, List<CatchProcessor> catchClauses, Processor finallyProcessor)

UnitOfWorkProcessor(Processor processor)

UnitOfWorkProcessor(RouteContext routeContext, Processor processor)

WrapProcessor(Processor processor, Processor wrapped)

Constructor parameters in org.apache.camel.processor with type arguments of type Processor

MulticastProcessor(CamelContext camelContext, Collection<Processor> processors)

MulticastProcessor(CamelContext camelContext, Collection<Processor> processors, AggregationStrategy aggregationStrategy)

MulticastProcessor(CamelContext camelContext, Collection<Processor> processors, AggregationStrategy aggregationStrategy, boolean parallelProcessing, ExecutorService executorService, boolean streaming, boolean stopOnException, long timeout, Processor onPrepare, boolean shareUnitOfWork)

Pipeline(CamelContext camelContext, Collection<Processor> processors)

Uses of Processor in org.apache.camel.processor.aggregate

Classes in org.apache.camel.processor.aggregate that implement Processor

class

AggregateProcessor An implementation of the Aggregator pattern where a batch of messages are processed (up to a maximum amount or until some timeout is reached) and messages for the same correlation key are combined together using some kind of AggregationStrategy (by default the latest message is used) to compress many message exchanges into a smaller number of exchanges.

Methods in org.apache.camel.processor.aggregate that return types with arguments of type Processor

List<Processor>

AggregateProcessor.next()

Constructors in org.apache.camel.processor.aggregate with parameters of type Processor

AggregateProcessor(CamelContext camelContext, Processor processor, Expression correlationExpression, AggregationStrategy aggregationStrategy, ExecutorService executorService)

Uses of Processor in org.apache.camel.processor.cache

Classes in org.apache.camel.processor.cache that implement Processor

class	CacheBasedMessageBodyReplacer
class	CacheBasedTokenReplacer
class	CacheBasedXPathReplacer

Uses of Processor in org.apache.camel.processor.idempotent

Classes in org.apache.camel.processor.idempotent that implement Processor

class

IdempotentConsumer An implementation of the Idempotent Consumer pattern.

Methods in org.apache.camel.processor.idempotent that return Processor

Processor

IdempotentConsumer.getProcessor()

Methods in org.apache.camel.processor.idempotent that return types with arguments of type Processor

List<Processor>

IdempotentConsumer.next()

Constructors in org.apache.camel.processor.idempotent with parameters of type Processor

IdempotentConsumer(Expression messageIdExpression, IdempotentRepository<String> idempotentRepository, boolean eager, boolean skipDuplicate, Processor processor)

Uses of Processor in org.apache.camel.processor.interceptor

Classes in org.apache.camel.processor.interceptor that implement Processor

class	DelayInterceptor An interceptor for delaying routes.
class	HandleFaultInterceptor
class	StreamCachingInterceptor An interceptor that converts streams messages into a re-readable format by wrapping the stream into a StreamCache.
class	TraceInterceptor An interceptor for debugging and tracing routes

Methods in org.apache.camel.processor.interceptor that return Processor

Processor	TraceInterceptorFactory.createTraceInterceptor(ProcessorDefinition node, Processor target, TraceFormatter formatter, Tracer tracer) Create a trace interceptor.
Processor	DefaultTraceInterceptorFactory.createTraceInterceptor(ProcessorDefinition node, Processor target, TraceFormatter formatter, Tracer tracer)
Processor	Tracer.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget)
Processor	StreamCaching.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget)
Processor	HandleFault.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget)
Processor	Delayer.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget)
Processor	Debug.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget)

Methods in org.apache.camel.processor.interceptor with parameters of type Processor

Processor	TraceInterceptorFactory.createTraceInterceptor(ProcessorDefinition node, Processor target, TraceFormatter formatter, Tracer tracer) Create a trace interceptor.
Processor	DefaultTraceInterceptorFactory.createTraceInterceptor(ProcessorDefinition node, Processor target, TraceFormatter formatter, Tracer tracer)
void	TraceEventHandler.traceExchange(ProcessorDefinition node, Processor target, TraceInterceptor traceInterceptor, Exchange exchange) Event called when an Exchange is about to be processed This event is only called if trace out has been disabled (which it is by default).
Object	TraceEventHandler.traceExchangeIn(ProcessorDefinition node, Processor target, TraceInterceptor traceInterceptor, Exchange exchange) Event called when an Exchange is about to be processed (in) This event is only called if trace out has been enabled.
void	TraceEventHandler.traceExchangeOut(ProcessorDefinition node, Processor target, TraceInterceptor traceInterceptor, Exchange exchange, Object traceState) Event called when an Exchange has been processed (out) This event is only called if trace out has been enabled.
Processor	Tracer.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget)
Processor	StreamCaching.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget)
Processor	HandleFault.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget)
Processor	Delayer.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget)
Processor	Debug.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget)

Constructors in org.apache.camel.processor.interceptor with parameters of type Processor

DelayInterceptor(ProcessorDefinition<?> node, Processor target, Delayer delayer)

HandleFaultInterceptor(Processor processor)

StreamCachingInterceptor(Processor processor)

TraceInterceptor(ProcessorDefinition node, Processor target, TraceFormatter formatter, Tracer tracer)

Uses of Processor in org.apache.camel.processor.loadbalancer

Subinterfaces of Processor in org.apache.camel.processor.loadbalancer

interface

LoadBalancer A strategy for load balancing across a number of Processor instances

Classes in org.apache.camel.processor.loadbalancer that implement Processor

class	FailOverLoadBalancer This FailOverLoadBalancer will failover to use next processor when an exception occurred This implementation mirrors the logic from the Pipeline in the async variation as the failover load balancer is a specialized pipeline.
class	LoadBalancerSupport A default base class for a LoadBalancer implementation.
class	QueueLoadBalancer A base class for LoadBalancer implementations which choose a single destination for each exchange (rather like JMS Queues)
class	RandomLoadBalancer Implements the random load balancing policy
class	RoundRobinLoadBalancer Implements the round robin load balancing policy
class	SimpleLoadBalancerSupport A default base class for a LoadBalancer implementation.
class	StickyLoadBalancer Implements a sticky load balancer using an Expression to calculate a correlation key to perform the sticky load balancing; rather like jsessionid in the web or JMSXGroupID in JMS.
class	TopicLoadBalancer A LoadBalancer implementations which sends to all destinations (rather like JMS Topics).
class	WeightedLoadBalancer
class	WeightedRandomLoadBalancer
class	WeightedRoundRobinLoadBalancer

Methods in org.apache.camel.processor.loadbalancer that return Processor

protected Processor	WeightedRoundRobinLoadBalancer.chooseProcessor(List<Processor> processors, Exchange exchange)
protected Processor	WeightedRandomLoadBalancer.chooseProcessor(List<Processor> processors, Exchange exchange)
protected Processor	StickyLoadBalancer.chooseProcessor(List<Processor> processors, Exchange exchange)
protected Processor	RoundRobinLoadBalancer.chooseProcessor(List<Processor> processors, Exchange exchange)
protected Processor	RandomLoadBalancer.chooseProcessor(List<Processor> processors, Exchange exchange)
protected abstract Processor	QueueLoadBalancer.chooseProcessor(List<Processor> processors, Exchange exchange)

Methods in org.apache.camel.processor.loadbalancer that return types with arguments of type Processor

List<Processor>	LoadBalancerSupport.getProcessors()
List<Processor>	LoadBalancer.getProcessors() Returns the current processors available to this load balancer
List<Processor>	LoadBalancerSupport.next()

Methods in org.apache.camel.processor.loadbalancer with parameters of type Processor

void	LoadBalancerSupport.addProcessor(Processor processor)
void	LoadBalancer.addProcessor(Processor processor) Adds a new processor to the load balancer
protected Exchange	TopicLoadBalancer.copyExchangeStrategy(Processor processor, Exchange exchange) Strategy method to copy the exchange before sending to another endpoint.
void	StickyLoadBalancer.removeProcessor(Processor processor)
void	LoadBalancerSupport.removeProcessor(Processor processor)
void	LoadBalancer.removeProcessor(Processor processor) Removes the given processor from the load balancer

Method parameters in org.apache.camel.processor.loadbalancer with type arguments of type Processor

protected Processor	WeightedRoundRobinLoadBalancer.chooseProcessor(List<Processor> processors, Exchange exchange)
protected Processor	WeightedRandomLoadBalancer.chooseProcessor(List<Processor> processors, Exchange exchange)
protected Processor	StickyLoadBalancer.chooseProcessor(List<Processor> processors, Exchange exchange)
protected Processor	RoundRobinLoadBalancer.chooseProcessor(List<Processor> processors, Exchange exchange)
protected Processor	RandomLoadBalancer.chooseProcessor(List<Processor> processors, Exchange exchange)
protected abstract Processor	QueueLoadBalancer.chooseProcessor(List<Processor> processors, Exchange exchange)

Constructors in org.apache.camel.processor.loadbalancer with parameters of type Processor

LoadBalancerConsumer(Endpoint endpoint, Processor processor, LoadBalancer loadBalancer)

Uses of Processor in org.apache.camel.processor.lucene

Classes in org.apache.camel.processor.lucene that implement Processor

class

LuceneQueryProcessor

Uses of Processor in org.apache.camel.processor.validation

Classes in org.apache.camel.processor.validation that implement Processor

class	PredicateValidatingProcessor A processor which validates the content of the inbound message body against a predicate.
class	ValidatingProcessor A processor which validates the XML version of the inbound message body against some schema either in XSD or RelaxNG

Uses of Processor in org.apache.camel.spi

Methods in org.apache.camel.spi that return Processor

Processor	ProcessorFactory.createChildProcessor(RouteContext routeContext, ProcessorDefinition<?> definition, boolean mandatory) Creates the child processor.
Processor	RouteContext.createProcessor(ProcessorDefinition<?> node) Creates a processor
Processor	ProcessorFactory.createProcessor(RouteContext routeContext, ProcessorDefinition<?> definition) Creates the processor.
Processor	Policy.wrap(RouteContext routeContext, Processor processor) Wraps any applicable interceptors around the given processor.
Processor	InterceptStrategy.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget) This method is invoked by ProcessorDefinition.wrapProcessor(RouteContext, Processor) to give the implementor an opportunity to wrap the target processor in a route.

Methods in org.apache.camel.spi with parameters of type Processor

void	RouteContext.addEventDrivenProcessor(Processor processor) Adds an event driven processor
boolean	Debugger.afterProcess(Exchange exchange, Processor processor, ProcessorDefinition definition, long timeTaken) Callback invoked when an Exchange has been processed which allows implementators to notify breakpoints.
void	Breakpoint.afterProcess(Exchange exchange, Processor processor, ProcessorDefinition definition, long timeTaken) Callback invoked when the breakpoint was hit and the Exchange has been processed (after).
void	UnitOfWork.afterProcess(Processor processor, Exchange exchange, AsyncCallback callback, boolean doneSync) Strategy for optional work to be executed after the processing
boolean	Debugger.beforeProcess(Exchange exchange, Processor processor, ProcessorDefinition definition) Callback invoked when an Exchange is about to be processed which allows implementators to notify breakpoints.
void	Breakpoint.beforeProcess(Exchange exchange, Processor processor, ProcessorDefinition definition) Callback invoked when the breakpoint was hit and the Exchange is about to be processed (before).
AsyncCallback	UnitOfWork.beforeProcess(Processor processor, Exchange exchange, AsyncCallback callback) Strategy for optional work to be execute before processing For example the MDCUnitOfWork leverages this to ensure MDC is handled correctly during routing exchanges using the asynchronous routing engine.
EventObject	EventFactory.createExchangeFailureHandledEvent(Exchange exchange, Processor failureHandler, boolean deadLetterChannel) Creates an EventObject when an Exchange has failed but was handled by the Camel error handlers such as an dead letter channel.
Object	ManagementObjectStrategy.getManagedObjectForErrorHandler(CamelContext context, RouteContext routeContext, Processor errorHandler, ErrorHandlerBuilder errorHandlerBuilder)
Object	ManagementObjectStrategy.getManagedObjectForProcessor(CamelContext context, Processor processor, ProcessorDefinition definition, Route route)
ObjectName	ManagementNamingStrategy.getObjectNameForErrorHandler(RouteContext routeContext, Processor errorHandler, ErrorHandlerBuilder builder)
ObjectName	ManagementNamingStrategy.getObjectNameForProcessor(CamelContext context, Processor processor, ProcessorDefinition<?> definition)
boolean	Condition.matchProcess(Exchange exchange, Processor processor, ProcessorDefinition definition) Does the condition match
void	LifecycleStrategy.onErrorHandlerAdd(RouteContext routeContext, Processor errorHandler, ErrorHandlerBuilder errorHandlerBuilder) Notification on adding error handler.
Processor	Policy.wrap(RouteContext routeContext, Processor processor) Wraps any applicable interceptors around the given processor.
Processor	InterceptStrategy.wrapProcessorInInterceptors(CamelContext context, ProcessorDefinition<?> definition, Processor target, Processor nextTarget) This method is invoked by ProcessorDefinition.wrapProcessor(RouteContext, Processor) to give the implementor an opportunity to wrap the target processor in a route.

Uses of Processor in org.apache.camel.spring.spi

Classes in org.apache.camel.spring.spi that implement Processor

class

TransactionErrorHandler The Transactional Client EIP pattern.

Methods in org.apache.camel.spring.spi that return Processor

Processor	TransactionErrorHandlerBuilder.createErrorHandler(RouteContext routeContext, Processor processor)
Processor	SpringTransactionPolicy.wrap(RouteContext routeContext, Processor processor)

Methods in org.apache.camel.spring.spi with parameters of type Processor

Processor	TransactionErrorHandlerBuilder.createErrorHandler(RouteContext routeContext, Processor processor)
protected TransactionErrorHandler	SpringTransactionPolicy.createTransactionErrorHandler(RouteContext routeContext, Processor processor, ErrorHandlerBuilder builder)
Processor	SpringTransactionPolicy.wrap(RouteContext routeContext, Processor processor)

Constructors in org.apache.camel.spring.spi with parameters of type Processor

TransactionErrorHandler(CamelContext camelContext, Processor output, CamelLogger logger, Processor redeliveryProcessor, RedeliveryPolicy redeliveryPolicy, ExceptionPolicyStrategy exceptionPolicyStrategy, org.springframework.transaction.support.TransactionTemplate transactionTemplate, Predicate retryWhile, String executorServiceRef)
Creates the transaction error handler.

Uses of Processor in org.apache.camel.test

Methods in org.apache.camel.test that return Processor

static Processor

TestSupport.unwrap(Processor processor) If a processor is wrapped with a bunch of DelegateProcessor or DelegateAsyncProcessor objects this call will drill through them and return the wrapped Processor.

Methods in org.apache.camel.test with parameters of type Processor

protected void	CamelTestSupport.debugAfter(Exchange exchange, Processor processor, ProcessorDefinition definition, String id, String shortName, long timeTaken) Single step debugs and Camel invokes this method after processing the given processor
protected void	CamelTestSupport.debugBefore(Exchange exchange, Processor processor, ProcessorDefinition definition, String id, String shortName) Single step debugs and Camel invokes this method before entering the given processor
static Processor	TestSupport.unwrap(Processor processor) If a processor is wrapped with a bunch of DelegateProcessor or DelegateAsyncProcessor objects this call will drill through them and return the wrapped Processor.
static Channel	TestSupport.unwrapChannel(Processor processor) If a processor is wrapped with a bunch of DelegateProcessor or DelegateAsyncProcessor objects this call will drill through them and return the Channel.

Uses of Processor in org.apache.camel.test.junit4

Methods in org.apache.camel.test.junit4 that return Processor

static Processor

TestSupport.unwrap(Processor processor) If a processor is wrapped with a bunch of DelegateProcessor or DelegateAsyncProcessor objects this call will drill through them and return the wrapped Processor.

Methods in org.apache.camel.test.junit4 with parameters of type Processor

protected void	CamelTestSupport.debugAfter(Exchange exchange, Processor processor, ProcessorDefinition definition, String id, String label, long timeTaken) Single step debugs and Camel invokes this method after processing the given processor
protected void	CamelTestSupport.debugBefore(Exchange exchange, Processor processor, ProcessorDefinition definition, String id, String label) Single step debugs and Camel invokes this method before entering the given processor
static Processor	TestSupport.unwrap(Processor processor) If a processor is wrapped with a bunch of DelegateProcessor or DelegateAsyncProcessor objects this call will drill through them and return the wrapped Processor.
static Channel	TestSupport.unwrapChannel(Processor processor) If a processor is wrapped with a bunch of DelegateProcessor or DelegateAsyncProcessor objects this call will drill through them and return the Channel.

Uses of Processor in org.apache.camel.testng

Methods in org.apache.camel.testng that return Processor

static Processor

TestSupport.unwrap(Processor processor) If a processor is wrapped with a bunch of DelegateProcessor or DelegateAsyncProcessor objects this call will drill through them and return the wrapped Processor.

Methods in org.apache.camel.testng with parameters of type Processor

protected void	CamelTestSupport.debugAfter(Exchange exchange, Processor processor, ProcessorDefinition definition, String id, String label, long timeTaken) Single step debugs and Camel invokes this method after processing the given processor
protected void	CamelTestSupport.debugBefore(Exchange exchange, Processor processor, ProcessorDefinition definition, String id, String label) Single step debugs and Camel invokes this method before entering the given processor
static Processor	TestSupport.unwrap(Processor processor) If a processor is wrapped with a bunch of DelegateProcessor or DelegateAsyncProcessor objects this call will drill through them and return the wrapped Processor.
static Channel	TestSupport.unwrapChannel(Processor processor) If a processor is wrapped with a bunch of DelegateProcessor or DelegateAsyncProcessor objects this call will drill through them and return the Channel.

Uses of Processor in org.apache.camel.util

Methods in org.apache.camel.util with parameters of type Processor

static void	EventHelper.notifyExchangeFailureHandled(CamelContext context, Exchange exchange, Processor failureHandler, boolean deadLetterChannel)
static void	EndpointHelper.pollEndpoint(Endpoint endpoint, Processor processor) Creates a PollingConsumer and polls all pending messages on the endpoint and invokes the given Processor to process each Exchange and then closes down the consumer and throws any exceptions thrown.
static void	EndpointHelper.pollEndpoint(Endpoint endpoint, Processor processor, long timeout) Creates a PollingConsumer and polls all pending messages on the endpoint and invokes the given Processor to process each Exchange and then closes down the consumer and throws any exceptions thrown.