Talend Mediation Components - Cloud - 8.0

cAggregate	Combines a number of messages together into a single message.

• Aggregating three messages into one

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)

cAWSConnection	Establishes a connection to Amazon Web Services for data storage and retrieval.
cAWSSES	Sends emails with Amazon's Simple Email Service (SES).

• Sending Email using the cAWSSES component

cAWSConnection	Establishes a connection to Amazon Web Services for data storage and retrieval.
cAWSSNS	Sends messages to an Amazon's Simple Notification topic.

• Sending messages to Amazon's SNS topic
• Sending messages to and receiving messages from Amazon's S3 service

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.

• Sending messages to and receiving messages from Amazon's SQS queue

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.

• Sending messages to and receiving messages from an AMQP broker

cREST	Provides integration with Apache CXF for connecting to JAX-RS services.
cSOAP	Provides integration with Apache CXF for connecting to JAX-WS services.

• Making an HTTP POST call to a REST service using cREST
• Providing a Web service from a Route Resource
• Providing a Web service using cSOAP from a Java class
• Providing a Web service using cSOAP from a WSDL file
• Providing and consuming a REST service using cREST

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.

cConfig	Sets the CamelContext using Java code.

• Implementing a dataset from the Registry

cContentEnricher	Uses a consumer or producer to obtain additional data, respectively intended for event messaging and request/reply messaging.

• Receiving messages from a list of URLs

cConvertBodyTo	Converts the message body to the given class type.

• Converting the body of an XML file into an org.w3c.dom.Document.class

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.

cJsonValidator	Validates the data based on the given JSON schema.
cXmlValidator	Validates the data based on the given XML schema.

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.

• Writing and reading data in an H2 database with an SQL statement

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 and synchronous messaging within the same JVM

cDynamicRouter	Routes a message or messages to different endpoints on specified conditions.

• Routing files conditionally to different file paths

cExchangePattern	Sets the message exchange mode in a Route.

• Enabling the InOut exchange pattern to get replies

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.

• Reading files from one directory and writing them to another

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.

• Deduplicating messages while routing them
• Filtering messages according to a criterion
• Routing messages according to a criterion
• Using cPipesAndFilters to process the task in sequence

cFlatPack	Processes fixed width or delimited files or messages using the FlatPack library

• Parsing delimited file using the cFlatPack component

cFtp	Provides access to remote file systems over the FTP, FTPS and SFTP protocols.
cHttp	Provides HTTP-based endpoints for consuming and producing HTTP resources.

• Retrieving the content of a remote file
• Using cHttp to produce a Web service

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.

• Sending and receiving a message from a JMS queue
• Sending and receiving a scheduled delivery of messages from a JMS Queue using Camel Quartz
• Setting up a JMS local transaction

cJsonParser	Extracts the desired data from JSON format.
cJsonWriter	Transforms the incoming data into JSON format.

• Extracting a JSON string into a map and converting the map back to JSON

cKafka	Communicates with Apache Kafka message broker.

cLoadBalancer	Distributes the messages it received to multiple endpoints according to the load balancing policy.

• Distributing messages to receiver endpoints based on round robin

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.

• Intercepting several routes and redirect them in a single new route
• Logging the exception thrown during a client/server talk
• Using cOnException to ignore exceptions and continue message routing
• Using cTry to build Try/Catch/Finally blocks for exception handling

cMail	Sends or receives mails in a Route.

• Using cMail to send and receive mails

cMap	Executes transformations (called maps) between different sources and destinations by harnessing the capabilities of , available in the perspective.

• Mapping data with cMap

cMessagingEndpoint	Allows two applications to communicate by either sending or receiving messages.

• Moving files from one message endpoint to another
• Sending files to another message endpoint
• Using an XQuery endpoint to filter messages

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.

• Sending messages to and receiving messages from an MQTT broker

cMulticast	Routes messages to a number of endpoints at one go and process them in different ways.

• Route a message to multiple endpoints and set a new body for each

cDelayer	Delays the delivery of messages.
cLoop	Processes messages repetitively and possibly in different ways.
cStop	Stops a message routing to which it is connected.
cTimer	Schedules message exchanges in a Route.

• Using cDelayer to delay message routing

cRecipientList	Routes messages to a number of dynamically specified recipients.

• Routing a message to multiple recipients

cTalendJob	Exchanges messages between a Data Integration Job and a Mediation Route.

• Using cTalendJob to call a DI Job

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 a message consecutively to a series of endpoints
• Routing each message conditionally to a series of endpoints

cSEDA	Produces and consumes messages asynchronously in different threads within a single CamelContext.
cVM	Produces and consumes messages asynchronously in different threads across CamelContext. You can use this mechanism to communicate across Web applications.

• Using cSEDA, cVM and cDirect to produce and consume messages separately

cSetBody	Sets the message body in the Route.

• Replacing the content of messages with their extracts

cSetHeader	Sets headers or customizes the default headers, if any, on each message sent to it for subsequent message processing.

• Splitting a message and renaming the sub-messages according to contained information

cSetProperty	Sets properties for each message sent to it for subsequent message processing.

cSplitter	Splits a message into several sub-messages so that they can be handled and treated differently in individual routes.

• Using cSplitter to split a message and aggregate replies from sub-messages

cDataset	Creates a new dataset or reference an existing dataset to send or receive messages.
cMock	Simulates message generation and message endpoints for testing Routes and mediation rules.

• Using cDataset to create messages

cThrottler	Limits the number of messages flowing to a specific endpoint in order to prevent it from getting overloaded.

• Throttling the message flow

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.

• Wiretapping a message in a Route

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.

cXmlParser	Extracts the desired data from XML format.
cXmlWriter	Transforms the incoming data into XML format.