Search Java Classes and Packages
#Org.apache.camel.processor Classes and Interfaces - 163 results found.
| Name | Description | Type | Package | Framework |
| AbstractListAggregationStrategy | Aggregate all exchanges into a List of values defined by the getValue(Exchange) call. | Class | org.apache.camel.processor.aggregate | Apache Camel |
| AggregateProcessor | An implementation of the Aggregator pattern where a batch of messages are processed (up to a maximum amount or | Class | org.apache.camel.processor.aggregate | Apache Camel |
| AggregationStrategy | A strategy for aggregating two exchanges together into a single exchange. | Interface | org.apache.camel.processor.aggregate | Apache Camel |
| AggregationStrategyBeanAdapter | An AggregationStrategy that adapts to a POJO. | Class | org.apache.camel.processor.aggregate | Apache Camel |
| AggregationStrategyBeanInfo | Class information about the POJO method to call when using the AggregationStrategyBeanAdapter. | Class | org.apache.camel.processor.aggregate | Apache Camel |
| AggregationStrategyMethodInfo | Method information about the POJO method to call when using the AggregationStrategyBeanAdapter. | Class | org.apache.camel.processor.aggregate | Apache Camel |
| AOPProcessor | Class | org.apache.camel.processor | Apache Camel | |
| BacklogDebugger | A Debugger that has easy debugging functionality which can be used from JMX with ManagedBacklogDebuggerMBean. | Class | org.apache.camel.processor.interceptor | Apache Camel |
| BacklogTracer | A tracer used for message tracing, storing a copy of the message details in a backlog. | Class | org.apache.camel.processor.interceptor | Apache Camel |
| BatchProcessor | A base class for any kind of Processor which implements some kind of batch processing. | Class | org.apache.camel.processor | Apache Camel |
| BindingException | An exception if a binding is not possible, such as binding to json or xml cannot be done. | Class | org.apache.camel.processor.binding | Apache Camel |
| CamelInternalProcessor | Internal Processor that Camel routing engine used during routing for cross cutting functionality such as: Execute UnitOfWorkKeeping track which route currently is being routedExecute RoutePolicyGather JMX performance staticsTracingDebuggingMessage HistoryStream Caching | Class | org.apache.camel.processor | Apache Camel |
| CamelInternalProcessor .BacklogDebuggerAdvice | Advice to execute the BacklogDebugger if enabled. | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel |
| CamelInternalProcessor .BacklogTracerAdvice | Advice to execute the BacklogTracer if enabled. | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel |
| CamelInternalProcessor .ChildUnitOfWorkProcessorAdvice | Advice when an EIP uses the shareUnitOfWork functionality. | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel |
| CamelInternalProcessor .DelayerAdvice | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel | |
| CamelInternalProcessor .InstrumentationAdvice | Advice for JMX instrumentation of the process being invoked. | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel |
| CamelInternalProcessor .MessageHistoryAdvice | Advice when Message History has been enabled. | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel |
| CamelInternalProcessor .RouteContextAdvice | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel | |
| CamelInternalProcessor .RouteInflightRepositoryAdvice | Advice to keep the InflightRepository up to date. | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel |
| CamelInternalProcessor .RouteLifecycleAdvice | Advice to invoke callbacks for before and after routing. | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel |
| CamelInternalProcessor .RoutePolicyAdvice | Advice to execute any RoutePolicy a route may have been configured with. | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel |
| CamelInternalProcessor .StreamCachingAdvice | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel | |
| CamelInternalProcessor .SubUnitOfWorkProcessorAdvice | Advice when an EIP uses the shareUnitOfWork functionality. | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel |
| CamelInternalProcessor .UnitOfWorkProcessorAdvice | Advice to inject new UnitOfWork to the Exchange if needed, and as well to ensure the UnitOfWork is done and stopped. | Class | org.apache.camel.processor.CamelInternalProcessor | Apache Camel |
| CamelInternalProcessorAdvice | An advice (before and after) to execute cross cutting functionality in the Camel routing engine. | Interface | org.apache.camel.processor | Apache Camel |
| 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 | org.apache.camel.processor | Apache Camel |
| CamelLogProcessor | 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 | org.apache.camel.processor | Apache Camel |
| CatchProcessor | A processor which catches exceptions. | Class | org.apache.camel.processor | Apache Camel |
| ChoiceProcessor | Class | org.apache.camel.processor | Apache Camel | |
| CircuitBreakerLoadBalancer | Class | org.apache.camel.processor.loadbalancer | Apache Camel | |
| ClosedCorrelationKeyException | The correlation key has been closed and the Exchange cannot be aggregated. | Class | org.apache.camel.processor.aggregate | Apache Camel |
| CompletionAwareAggregationStrategy | A specialized AggregationStrategy which has callback when the aggregated Exchange is completed. | Interface | org.apache.camel.processor.aggregate | Apache Camel |
| ConvertBodyProcessor | A processor which converts the payload of the input message to be of the given type If the conversion fails an InvalidPayloadException is thrown. | Class | org.apache.camel.processor | Apache Camel |
| DataFormatBinding | Represents a Binding which Marshals the message in the ProduceProcessor and Unmarshals the message in the ConsumeProcessor | Class | org.apache.camel.processor.binding | Apache Camel |
| DeadLetterChannel | Class | org.apache.camel.processor | Apache Camel | |
| Debug | A debug interceptor to notify Debugger with Exchanges being processed. | Class | org.apache.camel.processor.interceptor | Apache Camel |
| DefaultBacklogTracerEventMessage | An event message holding the traced message by the BacklogTracer. | Class | org.apache.camel.processor.interceptor | Apache Camel |
| DefaultChannel | DefaultChannel is the default Channel. | Class | org.apache.camel.processor.interceptor | Apache Camel |
| DefaultErrorHandler | Class | org.apache.camel.processor | Apache Camel | |
| DefaultExceptionPolicyStrategy | The default strategy used in Camel to resolve the OnExceptionDefinition that should handle the thrown exception. | Class | org.apache.camel.processor.exceptionpolicy | Apache Camel |
| DefaultExchangeComparator | Compares elements of an Exchange sequence by comparing long values returned by this comparator's | Class | org.apache.camel.processor.resequencer | Apache Camel |
| DefaultExchangeFormatter | Default ExchangeFormatter that have fine grained options to configure what to include in the output. | Class | org.apache.camel.processor | Apache Camel |
| DefaultExchangeFormatter .OutputStyle | Class | org.apache.camel.processor.DefaultExchangeFormatter | Apache Camel | |
| DefaultTraceEventHandler | Class | org.apache.camel.processor.interceptor | Apache Camel | |
| DefaultTraceEventMessage | Default TraceEventMessage. | Class | org.apache.camel.processor.interceptor | Apache Camel |
| DefaultTraceFormatter | Class | org.apache.camel.processor.interceptor | Apache Camel | |
| DefaultTraceInterceptorFactory | Class | org.apache.camel.processor.interceptor | Apache Camel | |
| DefaultValidationErrorHandler | A default error handler which just stores all the errors so they can be reported or transformed. | Class | org.apache.camel.processor.validation | Apache Camel |
| Delayer | delays processing the exchange until the correct amount of time has elapsed using an expression to determine the delivery time. | Class | org.apache.camel.processor | Apache Camel |
| Delayer | An interceptor strategy for delaying routes. | Class | org.apache.camel.processor.interceptor | Apache Camel |
| DelayInterceptor | An interceptor for delaying routes. | Class | org.apache.camel.processor.interceptor | Apache Camel |
| DelayProcessorSupport | A useful base class for any processor which provides some kind of throttling or delayed processing. | Class | org.apache.camel.processor | Apache Camel |
| DelegateAsyncProcessor | A Delegate pattern which delegates processing to a nested AsyncProcessor which can be useful for implementation inheritance when writing an Policy | Class | org.apache.camel.processor | Apache Camel |
| DelegateProcessor | A Delegate pattern which delegates processing to a nested Processor which can be useful for implementation inheritance when writing an Policy | Class | org.apache.camel.processor | Apache Camel |
| DelegateSyncProcessor | A Delegate pattern which delegates synchronous processing to a nested Processor which can be useful for implementation inheritance when writing an Policy | Class | org.apache.camel.processor | Apache Camel |
| DistributionRatio | Class | org.apache.camel.processor.loadbalancer | Apache Camel | |
| DynamicRouter | where the destination(s) is computed at runtime. | Class | org.apache.camel.processor | Apache Camel |
| Enricher | A content enricher that enriches input data by first obtaining additional data from a resource represented by an endpoint producer | Class | org.apache.camel.processor | Apache Camel |
| ErrorHandlerSupport | Support class for ErrorHandler implementations. | Class | org.apache.camel.processor | Apache Camel |
| EvaluateExpressionProcessor | A Processor which evaluates an Expression and stores the result as a property on the Exchange with the key | Class | org.apache.camel.processor | Apache Camel |
| ExceptionPolicyKey | Exception policy key is a compound key for storing: route id + exception class + when => exception type. | Class | org.apache.camel.processor.exceptionpolicy | Apache Camel |
| ExceptionPolicyStrategy | A strategy to determine which OnExceptionDefinition should handle the thrownSee Also:DefaultExceptionPolicy | Interface | org.apache.camel.processor.exceptionpolicy | Apache Camel |
| ExchangePatternProcessor | Processor to set ExchangePattern on the Exchange. | Class | org.apache.camel.processor | Apache Camel |
| ExpressionResultComparator | A SequenceElementComparator that compares Exchanges based on the result of an expression evaluation. | Interface | org.apache.camel.processor.resequencer | Apache Camel |
| 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 | Class | org.apache.camel.processor.loadbalancer | Apache Camel |
| FatalFallbackErrorHandler | An ErrorHandler used as a safe fallback when processing by other error handlers such as the OnExceptionDefinition. | Class | org.apache.camel.processor | Apache Camel |
| FileIdempotentRepository | A file based implementation of IdempotentRepository. | Class | org.apache.camel.processor.idempotent | Apache Camel |
| FilterProcessor | The processor which implements the Message Filter EIP pattern. | Class | org.apache.camel.processor | Apache Camel |
| FinallyProcessor | Class | org.apache.camel.processor | Apache Camel | |
| GroupedExchangeAggregationStrategy | Aggregate all exchanges into a single combined Exchange holding all the aggregated exchanges in a List of Exchange as the message body. | Class | org.apache.camel.processor.aggregate | Apache Camel |
| HandleFault | Class | org.apache.camel.processor.interceptor | Apache Camel | |
| HandleFaultInterceptor | Class | org.apache.camel.processor.interceptor | Apache Camel | |
| IdempotentConsumer | An implementation of the Idempotent Consumer pattern. | Class | org.apache.camel.processor.idempotent | Apache Camel |
| IdempotentOnCompletion | On completion strategy for IdempotentConsumer. | Class | org.apache.camel.processor.idempotent | Apache Camel |
| InterceptEndpointProcessor | Endpoint intercept processor so we know the processor is supposed to intercept an endpoint. | Class | org.apache.camel.processor | Apache Camel |
| InterceptorToAsyncProcessorBridge | A bridge to have regular interceptors implemented as Processor work with the asynchronous routing engine without causing side effects. | Class | org.apache.camel.processor | Apache Camel |
| LoadBalancer | Interface | org.apache.camel.processor.loadbalancer | Apache Camel | |
| LoadBalancerConsumer | Represents a consumer which on starting registers itself with a LoadBalancer and on closing unregisters itself with a load balancer | Class | org.apache.camel.processor.loadbalancer | Apache Camel |
| LoadBalancerSupport | A default base class for a LoadBalancer implementation. | Class | org.apache.camel.processor.loadbalancer | Apache Camel |
| LoggingErrorHandler | Class | org.apache.camel.processor | Apache Camel | |
| LogProcessor | A processor which evaluates an Expression and logs it. | Class | org.apache.camel.processor | Apache Camel |
| LoopProcessor | The processor which sends messages in a loop. | Class | org.apache.camel.processor | Apache Camel |
| MarshalProcessor | Class | org.apache.camel.processor | Apache Camel | |
| MemoryAggregationRepository | A memory based AggregationRepository which stores Exchanges in memory only. | Class | org.apache.camel.processor.aggregate | Apache Camel |
| MemoryIdempotentRepository | A memory based implementation of IdempotentRepository. | Class | org.apache.camel.processor.idempotent | Apache Camel |
| MessageRejectedException | An exception thrown if message is rejected by the resequencerVersion:See Also:Serialized Form | Class | org.apache.camel.processor.resequencer | Apache Camel |
| MulticastProcessor | endpoints, each endpoint receiving a copy of the message exchange. | Class | org.apache.camel.processor | Apache Camel |
| NoMessageIdException | An exception thrown if no message ID could be found on a message which is to be used with the Idempotent Consumer pattern. | Class | org.apache.camel.processor.idempotent | Apache Camel |
| NoXmlBodyValidationException | An exception found if no XML body is available on the inbound messageVersion:See Also:Serialized Form | Class | org.apache.camel.processor.validation | Apache Camel |
| NoXmlHeaderValidationException | An exception thrown if the XML header is not available on the inbound messageVersion:See Also:Serialized Form | Class | org.apache.camel.processor.validation | Apache Camel |
| OnCompletionProcessor | Processor implementing onCompletion. | Class | org.apache.camel.processor | Apache Camel |
| OptimisticLockingAwareAggregationStrategy | A specialized AggregationStrategy which gets a callback when the aggregated Exchange fails to add in the OptimisticLockingAggregationRepository because of | Interface | org.apache.camel.processor.aggregate | Apache Camel |
| OptimisticLockRetryPolicy | Class to control how failed optimistic locks are tried. | Class | org.apache.camel.processor.aggregate | Apache Camel |
| 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 | org.apache.camel.processor | Apache Camel |
| PipelineHelper | Class | org.apache.camel.processor | Apache Camel | |
| PollEnricher | A content enricher that enriches input data by first obtaining additional data from a resource represented by an endpoint producer | Class | org.apache.camel.processor | Apache Camel |
| PredicateValidatingProcessor | A processor which validates the content of the inbound message body against a Predicate. | Class | org.apache.camel.processor.validation | Apache Camel |
| PredicateValidationException | A predicate validation exception occurredVersion:See Also:Serialized Form | Class | org.apache.camel.processor.validation | Apache Camel |
| Processor | A processor is used to implement the Event Driven Consumer | Interface | org.apache.camel | Apache Camel |
| ProcessorExchangePair | Exchange pair to be executed by MulticastProcessor. | Interface | org.apache.camel.processor | Apache Camel |
| QueueLoadBalancer | A base class for LoadBalancer implementations which choose a single destination for each exchange (rather like JMS Queues) | Class | org.apache.camel.processor.loadbalancer | Apache Camel |
| RandomLoadBalancer | Class | org.apache.camel.processor.loadbalancer | Apache Camel | |
| RecipientList | pattern where the list of actual endpoints to send a message exchange to are dependent on some dynamic expression. | Class | org.apache.camel.processor | Apache Camel |
| RecipientListProcessor | pattern where the list of actual endpoints to send a message exchange to are dependent on some dynamic expression. | Class | org.apache.camel.processor | Apache Camel |
| RedeliveryErrorHandler | Base redeliverable error handler that also supports a final dead letter queue in case all redelivery attempts fail. | Class | org.apache.camel.processor | Apache Camel |
| RedeliveryPolicy | The policy used to decide how many times to redeliver and the time between the redeliveries before being sent to a Dead Letter | Class | org.apache.camel.processor | Apache Camel |
| RemoveHeaderProcessor | Class | org.apache.camel.processor | Apache Camel | |
| RemoveHeadersProcessor | Class | org.apache.camel.processor | Apache Camel | |
| RemovePropertiesProcessor | Class | org.apache.camel.processor | Apache Camel | |
| RemovePropertyProcessor | Class | org.apache.camel.processor | Apache Camel | |
| Resequencer | An implementation of the Resequencer which can reorder messages within a batch. | Class | org.apache.camel.processor | Apache Camel |
| ResequencerEngine | Resequences elements based on a given SequenceElementComparator. | Class | org.apache.camel.processor.resequencer | Apache Camel |
| RestBindingProcessor | A Processor that binds the REST DSL incoming and outgoing messages from sources of json or xml to Java Objects. | Class | org.apache.camel.processor.binding | Apache Camel |
| RollbackProcessor | Processor for marking an Exchange to rollback. | Class | org.apache.camel.processor | Apache Camel |
| RoundRobinLoadBalancer | Class | org.apache.camel.processor.loadbalancer | Apache Camel | |
| RoutingSlip | pattern where the list of actual endpoints to send a message exchange to are dependent on the value of a message header. | Class | org.apache.camel.processor | Apache Camel |
| RoutingSlip .RoutingSlipIterator | The iterator to be used for retrieving the next routing slip(s) to be used. | Interface | org.apache.camel.processor.RoutingSlip | Apache Camel |
| SamplingThrottler | A SamplingThrottler is a special kind of throttler. | Class | org.apache.camel.processor | Apache Camel |
| SchemaValidationException | A Schema validation exception occurredVersion:See Also:Serialized Form | Class | org.apache.camel.processor.validation | Apache Camel |
| SendProcessor | Processor for forwarding exchanges to an endpoint destination. | Class | org.apache.camel.processor | Apache Camel |
| Sequence | A sorted set of elements with additional methods for obtaining immediate successors and immediate predecessors of a given element in the sequence. | Class | org.apache.camel.processor.resequencer | Apache Camel |
| SequenceElementComparator | A strategy for comparing elements of a sequence. | Interface | org.apache.camel.processor.resequencer | Apache Camel |
| SequenceSender | An interface used by the ResequencerEngine. | Interface | org.apache.camel.processor.resequencer | Apache Camel |
| SetBodyProcessor | Class | org.apache.camel.processor | Apache Camel | |
| SetHeaderProcessor | Class | org.apache.camel.processor | Apache Camel | |
| SetPropertyProcessor | Class | org.apache.camel.processor | Apache Camel | |
| SimpleLoadBalancerSupport | A default base class for a LoadBalancer implementation. | Class | org.apache.camel.processor.loadbalancer | Apache Camel |
| SortProcessor | Class | org.apache.camel.processor | Apache Camel | |
| Splitter | 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 | org.apache.camel.processor | Apache Camel |
| StickyLoadBalancer | a correlation key to perform the sticky load balancing; rather like jsessionid in the web or JMSXGroupID in JMS. | Class | org.apache.camel.processor.loadbalancer | Apache Camel |
| StopProcessor | Stops continue processing the route and marks it as complete. | Class | org.apache.camel.processor | Apache Camel |
| StreamCaching | Class | org.apache.camel.processor.interceptor | Apache Camel | |
| StreamCachingInterceptor | An interceptor that converts streams messages into a re-readable format by wrapping the stream into a StreamCache. | Class | org.apache.camel.processor.interceptor | Apache Camel |
| StreamResequencer | A resequencer that re-orders a (continuous) stream of Exchanges. | Class | org.apache.camel.processor | Apache Camel |
| ThreadsProcessor | Threads processor that leverage a thread pool for continue processing the Exchanges using the asynchronous routing engine. | Class | org.apache.camel.processor | Apache Camel |
| 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 | org.apache.camel.processor | Apache Camel |
| ThrottlerRejectedExecutionException | Class | org.apache.camel.processor | Apache Camel | |
| ThroughputLogger | A logger for logging message throughput. | Class | org.apache.camel.processor | Apache Camel |
| ThrowExceptionProcessor | Class | org.apache.camel.processor | Apache Camel | |
| Timeout | A timer task that notifies handlers about scheduled timeouts. | Class | org.apache.camel.processor.resequencer | Apache Camel |
| TimeoutAwareAggregationStrategy | A specialized AggregationStrategy which can handle timeouts as well. | Interface | org.apache.camel.processor.aggregate | Apache Camel |
| TimeoutHandler | Interface | org.apache.camel.processor.resequencer | Apache Camel | |
| TopicLoadBalancer | A LoadBalancer implementations which sends to all destinations (rather like JMS Topics). | Class | org.apache.camel.processor.loadbalancer | Apache Camel |
| TraceEventHandler | A handler which reacts on trace events. | Interface | org.apache.camel.processor.interceptor | Apache Camel |
| TraceEventMessage | A trace event message that contains decomposed information about the traced Exchange at the point of interception. | Interface | org.apache.camel.processor.interceptor | Apache Camel |
| TraceFormatter | Formatter to format trace logs when tracing Exchange during routing. | Interface | org.apache.camel.processor.interceptor | Apache Camel |
| TraceInterceptor | Class | org.apache.camel.processor.interceptor | Apache Camel | |
| TraceInterceptorFactory | Factory to create the trace interceptor. | Interface | org.apache.camel.processor.interceptor | Apache Camel |
| Tracer | Class | org.apache.camel.processor.interceptor | Apache Camel | |
| TransformProcessor | Class | org.apache.camel.processor | Apache Camel | |
| TryProcessor | Class | org.apache.camel.processor | Apache Camel | |
| UnitOfWorkProducer | Ensures a Producer is executed within an UnitOfWork. | Class | org.apache.camel.processor | Apache Camel |
| UnmarshalProcessor | Class | org.apache.camel.processor | Apache Camel | |
| UseLatestAggregationStrategy | An AggregationStrategy which just uses the latest exchange which is useful for status messages where old status messages have no real value. | Class | org.apache.camel.processor.aggregate | Apache Camel |
| UseOriginalAggregationStrategy | An AggregationStrategy which just uses the original exchange which can be needed when you want to preserve the original Exchange. | Class | org.apache.camel.processor.aggregate | Apache Camel |
| ValidatingProcessor | A processor which validates the XML version of the inbound message body against some schema either in XSD or RelaxNG | Class | org.apache.camel.processor.validation | Apache Camel |
| ValidatorErrorHandler | Validator error handler. | Interface | org.apache.camel.processor.validation | Apache Camel |
| WeightedLoadBalancer | Class | org.apache.camel.processor.loadbalancer | Apache Camel | |
| WeightedRandomLoadBalancer | Class | org.apache.camel.processor.loadbalancer | Apache Camel | |
| WeightedRoundRobinLoadBalancer | Class | org.apache.camel.processor.loadbalancer | Apache Camel | |
| WireTapProcessor | Processor for wire tapping exchanges to an endpoint destination. | Class | org.apache.camel.processor | Apache Camel |
| WrapProcessor | A processor which ensures wrapping processors is having lifecycle handled. | Class | org.apache.camel.processor | Apache Camel |