Aggregate
Aggregate component
cAggregate | Combines a number of messages together into a single message. |
Aggregate scenario
Amazon S3
Amazon S3 components
cAWSConnection | Establishes a connection to Amazon Web Services for data storage and retrieval. |
cAWSS3 | Stores and retrieves objects from/to Amazon's Simple Storage Service (S3) |
Amazon SES
Amazon SES components
cAWSConnection | Establishes a connection to Amazon Web Services for data storage and retrieval. |
cAWSSES | Sends emails with Amazon's Simple Email Service (SES). |
Amazon SES scenario
Amazon SNS
Amazon SNS components
cAWSConnection | Establishes a connection to Amazon Web Services for data storage and retrieval. |
cAWSSNS | Sends messages to an Amazon's Simple Notification topic. |
Amazon SNS scenarios
Amazon SQS
Amazon SQS components
cAWSConnection | Establishes a connection to Amazon Web Services for data storage and retrieval. |
cAWSSQS | Sends and receives messages to/from Amazon's Simple Queue Service (SQS). The AWS SQS FIFO Feature for Queues are supported. |
Amazon SQS scenario
AMQP
AMQP components
cAMQP | Exchanges messages between a Route and a JMS provider using the AMQP broker. |
cMQConnectionFactory | Encapsulates a set of configuration parameters to connect to a MQ server. The connection can be called by multiple cJMS, cWMQ, cAMQP or cMQTT components in a Route. |
AMQP scenario
Apache CXF
Apache CXF components
Apache CXF scenarios
Bean
Bean components
cBean | Invokes a Java bean that is stored in the Code node of the Repository or registered by a cBeanRegister. |
cBeanRegister | Registers a Java bean in the registry to be used in message exchanges. |
CamelContext
CamelContext component
cConfig | Sets the CamelContext using Java code. |
CamelContext scenario
Content Enricher
Content Enricher component
cContentEnricher | Uses a consumer or producer to obtain additional data, respectively intended for event messaging and request/reply messaging. |
Content Enricher scenario
ConvertBody
ConvertBody component
cConvertBodyTo | Converts the message body to the given class type. |
ConvertBody scenario
Custom code
Custom code components
cJavaDSLProcessor | Implements producers and consumers of message exchanges or implements a message translator using the Java Domain Specific Language (DSL). |
cProcessor | Implements consumers of message exchanges or implements a Message Translator. |
Data Quality
Validation
Validation components
cJsonValidator | Validates the data based on the given JSON schema. |
cXmlValidator | Validates the data based on the given XML schema. |
Database
Database components
cSQL | Reads from and writes to any database using a SQL connection based on a query. |
cSQLConnection | Opens a connection to the specified database that can then be reused in the subsequent subRoute. |
Database scenario
Direct
Direct components
cDirect | Produces and consumes messages synchronously in different threads within a single CamelContext. |
cDirectVM | Produces and consumes messages synchronously in different threads within a single CamelContext and across CamelContexts in the same JVM. You can use this mechanism to communicate across Web applications. |
Direct scenario
Dynamic Router
Dynamic Router component
cDynamicRouter | Routes a message or messages to different endpoints on specified conditions. |
Dynamic Router scenario
Exchange
Exchange component
cExchangePattern | Sets the message exchange mode in a Route. |
Exchange scenario
File
File component
cFile | Provides access to file systems, allowing files to be processed by any other components or messages from other components to be saved to the disk. |
File scenario
Filter
Filter components
cIdempotentConsumer | Identifies messages that have already been sent to the receiver and eliminates them. Messages are still sent by the sender but are ignored by the receiver at the delivery stage. |
cMessageFilter | Filters the content of messages according to the specified criterion and routes the filtered messages to the specified output channel. All messages that do not match the criteria will be dropped. |
cMessageRouter | Creates different channels for each filtered message type according to specified conditions so that messages can later on be treated more accurately in each new channel. |
cPipesAndFilters | Splits message routing into a series of independent processing stages. |
Filter scenarios
Flatpack
Flatpack component
cFlatPack | Processes fixed width or delimited files or messages using the FlatPack library |
Flatpack scenario
Internet
Internet components
Internet scenarios
JMS
JMS components
cJMS | Exchanges messages between a Route and a JMS provider. |
cMQConnectionFactory | Encapsulates a set of configuration parameters to connect to a MQ server. The connection can be called by multiple cJMS, cWMQ, cAMQP or cMQTT components in a Route. |
JMS scenarios
JSON processing
JSON processing components
cJsonParser | Extracts the desired data from JSON format. |
cJsonWriter | Transforms the incoming data into JSON format. |
JSON processing scenario
Kafka
Kafka component
cKafka | Communicates with Apache Kafka message broker. |
Load Balancer
Load Balancer component
cLoadBalancer | Distributes the messages it received to multiple endpoints according to the load balancing policy. |
Load Balancer scenario
Logs and errors
Logs and errors components
cErrorHandler | Processes errors in the message routing. |
cIntercept | Intercepts each message sub-route and redirects it in another sub-route without modifying the original one. When this detour is complete, message routing to the originally intended target endpoints continues. This can be useful at testing time to simulate error handling. |
cLog | Logs message exchanges in a Route. |
cOnException | Catches the exceptions defined and triggers certain actions which are then performed on these exceptions and the message routing. |
cTry | Offers the Java equivalent exception handling abilities by building Try/Catch/Finally blocks to isolate the part of your Route likely to generate an error, catch the errors, and execute final instructions regardless of the errors. |
Logs and errors scenarios
Mail component
cMail | Sends or receives mails in a Route. |
Mail scenario
Map
Map component
cMap | Executes transformations (called maps) between different sources and destinations by harnessing the capabilities of , available in the perspective. |
Map scenario
Messaging Endpoint
Messaging Endpoint component
cMessagingEndpoint | Allows two applications to communicate by either sending or receiving messages. |
Messaging Endpoint scenarios
MQTT
MQTT components
cMQConnectionFactory | Encapsulates a set of configuration parameters to connect to a MQ server. The connection can be called by multiple cJMS, cWMQ, cAMQP or cMQTT components in a Route. |
cMQTT | Sends messages to, or consumes messages from MQTT compliant message brokers. |
MQTT scenario
Multicast
Multicast component
cMulticast | Routes messages to a number of endpoints at one go and process them in different ways. |
Multicast scenario
Orchestration
Orchestration components
Orchestration scenario
Recipient List
Recipient List component
cRecipientList | Routes messages to a number of dynamically specified recipients. |
Recipient List scenario
Route
Route component
cTalendJob | Exchanges messages between a Data Integration Job and a Mediation Route. |
Route scenario
Routing Slip
Routing Slip component
cRoutingSlip | Routes the message consecutively through a series of processing steps, with the sequence of steps unknown at design time and variable for each message. |
Routing Slip scenarios
SEDA
SEDA components
SEDA scenario
SetBody
SetBody component
cSetBody | Sets the message body in the Route. |
SetBody scenario
SetHeader
SetHeader component
cSetHeader | Sets headers or customizes the default headers, if any, on each message sent to it for subsequent message processing. |
SetHeader scenario
SetProperty
SetProperty component
cSetProperty | Sets properties for each message sent to it for subsequent message processing. |
Splitter
Splitter component
cSplitter | Splits a message into several sub-messages so that they can be handled and treated differently in individual routes. |
Splitter scenario
Testing
Testing components
Testing scenario
Throttler
Throttler component
cThrottler | Limits the number of messages flowing to a specific endpoint in order to prevent it from getting overloaded. |
Throttler scenario
Wiretap
Wiretap component
cWireTap | Wiretaps messages to a user defined URI while they are sent to their original endpoint. cWireTap also allows you to populate a new message to this wiretap URI concurrently. |
Wiretap scenario
WMQ
WMQ components
cMQConnectionFactory | Encapsulates a set of configuration parameters to connect to a MQ server. The connection can be called by multiple cJMS, cWMQ, cAMQP or cMQTT components in a Route. |
cWMQ | Exchanges messages between a Route and a JMS provider using WMQ. |
XML processing
XML processing components
cXmlParser | Extracts the desired data from XML format. |
cXmlWriter | Transforms the incoming data into XML format. |