Camel Components

Talend ESB Mediation Developer Guide

EnrichVersion
6.2
EnrichProdName
Talend ESB
task
Installation and Upgrade
Design and Development
EnrichPlatform
Talend ESB

The following Camel components are discussed within this guide:

Component / ArtifactId / URI

Description

Camel Component: ActiveMQ / activemq-camel

activemq:[topic:]destinationName

For JMS Messaging with Apache ActiveMQ

Camel Component: AHC / camel-ahc

ahc:http[s]://hostname[:port][/resourceUri][?options]

To call external HTTP services using Async Http Client

Camel Component: Atom / camel-atom

atom:uri

Working with Apache Abdera for atom integration, such as consuming an atom feed.

Camel Component: Apns / camel-apns

apns:<notify|consumer>[?options]

For sending notifications to Apple iOS devices

Camel Component: Avro / camel-avro

avro:[transport]:[host]:[port][/messageName][?options]

Working with Apache Avro for data serialization.

Camel Component: Bean / camel-core

bean:beanName[?method=someMethod]

Uses the Camel Bean Binding to bind message exchanges to beans in the Camel Registry. Is also used for exposing and invoking POJO (Plain Old Java Objects).

Camel Component: Cache / camel-cache

cache://cachename[?options]

The cache component facilitates creation of caching endpoints and processors using EHCache as the cache implementation.

Camel Component: Class / camel-core

class:className[?method=someMethod]

Uses the Camel Bean Binding to bind message exchanges to beans in the Camel Registry. Is also used for exposing and invoking POJOs (Plain Old Java Objects).

Camel Component: CMIS / camel-cmis

cmis://cmisServerUrl[?options]

Uses the Apache Chemistry client API to interface with CMIS supporting CMS

Camel Component: Context / camel-context

context:camelContextId: localEndpointName

Used to refer to endpoints within a separate CamelContext to provide a simple black box composition approach so that routes can be combined into a CamelContext and then used as a black box component inside other routes in other CamelContexts

Camel Component: CouchDB / camel-couchdb

couchdb:hostName[:port]/database[?options]

To integrate with Apache CouchDB.

Camel Component: Crypto (Digital Signatures)

crypto:sign:name[?options], crypto:verify:name[?options]

Used to sign and verify exchanges using the Signature Service of the Java Cryptographic Extension.

Camel Component: CXF / camel-cxf

cxf:address[?serviceClass=...]

Working with Apache CXF for web services integration

Camel Component: CXF Bean / camel-cxf

cxf:bean name

Process the exchange using a JAX WS or JAX RS annotated bean from the registry. Requires less configuration than the above CXF Component.

Camel Component: CXFRS / camel-cxf

cxfrs:address[?resourcesClasses=...]

Working with Apache CXF for REST services integration

Camel Component: Direct / camel-core

direct:name

Synchronous call to another endpoint from same CamelContext

Camel Component: Disruptor / camel-disruptor

disruptor:someName[?<option>]

disruptor-vm:someName[?<option>]

To provide the implementation of SEDA which is based on disruptor

Camel Component: ElasticSearch / camel-elasticsearch

elasticsearch://clusterName[?options]

For interfacing with an ElasticSearch server.

Camel Component: Spring Event / camel-spring

spring-event://default[?options]

Working with Spring ApplicationEvents

Camel Component: Exec / camel-exec

exec://executable[?options]

For executing system commands

Camel Component: Facebook / camel-facebook

facebook://endpoint[?options]

Providing access to all of the Facebook APIs accessible using Facebook4J

Camel Component: File / camel-core

file://nameOfFileOrDirectory

Sending messages to a file or polling a file or directory.

Camel Component: Flatpack / camel-flatpack

flatpack:[fixed|delim]:configFile

Processing fixed width or delimited files or messages using the FlatPack library

Camel Component: FOP / camel-fop

fop:outputFormat[?options]

Renders the message into different output formats using Apache FOP

Camel Component: Freemarker / camel-freemarker

freemarker:someTemplateResource

Generates a response using a Freemarker template

Camel Component: FTP / camel-ftp

ftp://host[:port]/fileName

Sending and receiving files over FTP.

Camel Component: FTP / camel-ftp (FTPS)

ftps://host[:port]/fileName

Sending and receiving files over FTP Secure (TLS and SSL).

Camel Component: Geocoder / camel-geocoder

geocoder:<address|latlng:latitude,longitude>[?options]

Supports looking up geocoders for an address, or reverse lookup geocoders from an address.

Camel Component: Guava EventBus / camel-guava-eventbus

guava-eventbus:busName[?options]

The Google Guava EventBus allows publish-subscribe-style communication between components without requiring the components to explicitly register with one another (and thus be aware of each other). This component provides integration bridge between Camel and Google Guava EventBus infrastructure.

Camel Component: HDFS / camel-hdfs

hdfs://hostName[:port][/path][?options]

For reading/writing from/to an HDFS filesystem using Hadoop 1.x

Camel Component: HDFS2 / camel-hdfs2

hdfs2://hostName[:port][/path][?options]

For reading/writing from/to an HDFS filesystem using Hadoop 2.x

Camel Component: Hl7

mina:tcp://hostname[:port]

For working with the HL7 MLLP protocol and the HL7 model using the HAPI library.

Camel Component: HTTP4 / camel-http4

http4://hostname[:port]

For calling out to external HTTP servers using Apache HTTP Client 4.x

Camel Component: Infinispan / camel-infinispan

infinispan://hostName[?options]

For reading/writing from/to Infinispan distributed key/value store and data grid

Camel Component: Mail / camel-mail

imap://hostname[:port]

Receiving email using IMap

Camel Component: Jasypt / camel-jasypt

jasypt: uri

Simplified on-the-fly encryption library, integrated with Camel.

Camel Component: JCR / camel-jcr

jcr://user:password@repository/path/to/node

Storing a message in a JCR (JSR-170) compliant repository like Apache Jackrabbit

Camel Component: JDBC / camel-jdbc

jdbc:dataSourceName?options

For performing JDBC queries and operations

Camel Component: Jetty / camel-jetty

jetty:url

For exposing services over HTTP

Camel Component: JGroups / camel-jgroups

jgroups:clusterName[?options]

The jgroups: component provides exchange of messages between Camel infrastructure and JGroups clusters.

Camel Component: JMS / camel-jms

jms:[topic:]destinationName

Working with JMS providers

Camel Component: JMX / camel-jmx

jmx://platform?options

For working with JMX notification listeners

Camel Component: JPA / camel-jpa

jpa://entityName

For using a database as a queue via the JPA specification for working with OpenJPA, Hibernate or TopLink

Camel Component: Jsch / camel-jsch

scp://localhost/destination

Support for the scp protocol.

Camel Component: Kafka / camel-kafka

kafka://server:port[?options]

For producing to or consuming from Apache Kafka message brokers.

Camel Component: Krati / camel-krati

krati://[path to datastore/][?options]

For producing to or consuming to Krati datastores

Camel Component: LDAP / camel-ldap

ldap:host[:port]?base=...[&scope=<scope>]

Performing searches on LDAP servers (<scope> must be one of object|onelevel|subtree)

Camel Component: Log / camel-core

log:loggingCategory[?level=ERROR]

Uses Jakarta Commons Logging to log the message exchange to some underlying logging system like log4j

Camel Component: Lucene / camel-lucene

lucene:searcherName:insert [?analyzer=<analyzer>]

Uses Apache Lucene to perform Java-based indexing and full text based searches using advanced analysis/tokenization capabilities

Camel Component: Mail / camel-mail

mail://user-info@host:port

Sending and receiving email

Camel Component: Mock / camel-core

mock:name

For testing routes and mediation rules using mocks

Camel Component: Mail / camel-mail

pop3://user-info@host:port

Receiving email using POP3 and JavaMail

Camel Component: MINA 2 / camel-mina2

mina2:[tcp|udp|vm]:host[:port][?options]

Working with Apache MINA 2.x

Camel Component: MongoDB / camel-mongodb

mongodb:connectionBean[?options]

Interacts with MongoDB databases and collections. Offers producer endpoints to perform CRUD-style operations and more against databases and collections, as well as consumer endpoints to listen on collections and dispatch objects to Camel routes

Camel Component: MQTT / camel-mqtt

mqtt:name[?options]

Component for communicating with MQTT M2M message brokers

Camel Component: Mustache / camel-mustache

mustache:templateName[?options]

Generates a response using a Mustache template

Camel Component: MyBatis / camel-mybatis

mybatis://statementName

Performs a query, poll, insert, update or delete in a relational database using MyBatis

Camel Component: OptaPlanner / camel-optaplanner

optaplanner:solverConfig[?options]

Solves the planning problem contained in a message with OptaPlanner.

Camel Component: Properties / camel-core

properties://key[?options]

The properties component facilitates using property placeholders directly in endpoint uri definitions.

Camel Component: Quartz / camel-quartz

quartz://groupName/timerName

Provides a scheduled delivery of messages using the Quartz scheduler

Camel Component: Quartz2 / camel-quartz2

quartz2://groupName/timerName[?options]

Provides a scheduled delivery of messages using the Quartz 2.x scheduler

Camel Component: Ref / camel-core

ref:name

Component for lookup of existing endpoints bound in the Camel Registry.

Camel Component: RabbitMQ / camel-rabbitmq

rabbitmq://hostname[:port]/exchangeName[?options]

Component for integrating with RabbitMQ

Camel Component: RMI / camel-rmi

rmi://host[:port]

Working with RMI

Camel Component: RSS / camel-rss

rss:uri

Working with ROME for RSS integration, such as consuming an RSS feed.

Camel Component: Salesforce / camel-salesforce

salesforce:topic[?options]

Working with ROME for RSS integration, such as consuming an RSS feed.

Camel Component: SAP NetWeaver / camel-sap-netweaver

sap-netweaver:hostName[:port][?options]

To integrate with Salesforce

Camel Component: SEDA / camel-core

seda:name

Asynchronous call to another endpoint in the same Camel Context

Camel Component: Servlet / camel-servlet

servlet:uri

For exposing services over HTTP through the servlet which is deployed into the Web container.

Camel Component: FTP / camel-ftp (SFTP)

sftp://host[:port]/fileName

Sending and receiving files over SFTP (FTP over SSH).

Camel Component: Mail / camel-mail

smtp://user-info@host[:port]

Sending email using SMTP and JavaMail

Camel Component: SJMS / camel-sjms

sjms:[queue:|topic:]destinationName[?options]

A ground up implementation of a JMS client

Camel Component: SMPP / camel-smpp

smpp://user-info@host[:port]?options

To send and receive SMS using Short Messaging Service Center using the JSMPP library

Camel Component: SNMP / camel-snmp

snmp://host[:port]?options

Polling OID values and receiving traps using SNMP via SNMP4J library

Camel Component: Solr / camel-solr

solr://hostName[:port]/solr[?options]

Uses the Solrj client API to interface with an Apache Lucene Solr server

Camel Component: Splunk / camel-splunk

splunk://[endpoint]?[options]

For working with Splunk

Camel Component: Spring Batch / camel-spring-batch

spring-batch:jobName[?options]

To bridge Camel and Spring Batch

Camel Component: Spring Integration / camel-spring-integration

spring-integration: defaultChannelName

The bridge component of Camel and Spring Integration

Camel Component: Spring LDAP / camel-spring-ldap

spring-ldap:springLdapTemplateBean[?options]

Camel wrapper for Spring LDAP

Camel Component: Spring Redis / camel-spring-redis

spring-redis://hostName:port[?options]

Component for consuming and producing from Redis key-value store Redis

Camel Component: Spring Web Services / camel-spring-ws

spring-ws:[mapping-type:]address[?options]

Client-side support for accessing web services, and server-side support for creating your own contract-first web services using Spring Web Services

Camel Component: SQL / camel-sql

sql:select * from table where id=#

Performing SQL queries using JDBC

Camel Component: SSH / camel-ssh

ssh:[username[:password]@]host [:port][?options]

For sending commands to a SSH server

Camel Component: StAX / camel-stax

stax:(contentHandlerClassName|#myHandler)

Process messages through a SAX ContentHandler.

Camel Component: Stomp / camel-stomp

stomp:queue:destinationName[?options]

For communicating with Stomp compliant message brokers, like Apache ActiveMQ or ActiveMQ Apollo

Camel Component: Stub

stub:someOtherCamelUri

Allows you to stub out some physical middleware endpoint for easier testing or debugging

Camel Component: Test / camel-spring

test:expectedMessagesEndpointUri

Creates a Camel Component: Mock endpoint which expects to receive all the message bodies that could be polled from the given underlying endpoint

Camel Component: Timer / camel-core

timer://name

A timer endpoint

Camel Component: Twitter / camel-twitter

twitter://endpoint[?options]

A twitter endpoint

Camel Component: Velocity / camel-vertx

vertx:eventBusName

Working with the vertx event bus

Camel Component: Vertx / camel-velocity

velocity:someTemplateResource

Generates a response using an Apache Velocity template

Camel Component: VM / camel-core

vm:name

Asynchronous call to another endpoint in the same JVM

Camel Component: Weather / camel-weather

wweather://name[?options]

Polls the weather information from Open Weather Map

Camel Component: Websocket / camel-websocket

websocket://hostname[:port][/resourceUri][?options]

Communicating with Websocket clients

Camel Component: XQuery / camel-saxon

xquery:someXQueryResource

Generates a response using an XQuery template

Camel Component: XSLT / camel-spring

xslt:someTemplateResource

Generates a response using an XSLT template

Camel Component: Yammer / camel-yammer

yammer://function[?options]

Allows you to interact with the Yammer enterprise social network

Camel Component: Zookeeper camel-zookeeper

zookeeper://zookeeperServer[:port][/path][?options]

Working with ZooKeeper cluster(s)