集計
Aggregateコンポーネント
cAggregate | 複数のメッセージを1つのメッセージに結合します。 |
Aggregateシナリオ
Amazon S3
Amazon S3のコンポーネント
cAWSConnection | データを保管および取得するAmazon Web Services (AWS)への接続を確立します。 |
cAWSS3 | Amazonのシンプルストレージサービス(S3)との間でオブジェクトの保管および取得を行います。 |
Amazon SES
Amazon SESコンポーネント
cAWSConnection | データを保管および取得するAmazon Web Services (AWS)への接続を確立します。 |
cAWSSES | AmazonのSimple Email Service (SES)でメールを送信します。 |
Amazon SESシナリオ
Amazon SNS
Amazon SNSコンポーネント
cAWSConnection | データを保管および取得するAmazon Web Services (AWS)への接続を確立します。 |
cAWSSNS | AmazonのSimple Notificationトピックにメッセージを送信します。 |
Amazon SNSシナリオ
Amazon SQS
Amazon SQSのコンポーネント
cAWSConnection | データを保管および取得するAmazon Web Services (AWS)への接続を確立します。 |
cAWSSQS | AmazonのSimple Queue Service (SQS)との間でメッセージを送受信します。キューのAWS SQS FIFO機能がサポートされています。 |
Amazon SQSのシナリオ
AMQP
AMQPコンポーネント
cAMQP | AMQPブローカーを使ってルートとJMSプロバイダーの間でメッセージを交換します。 |
cMQConnectionFactory | MQサーバーに接続するための設定パラメーターのセットをカプセル化します。接続は、ルート内の複数のコンポーネントcJMS、cWMQ、cAMQP、またはcMQTTによって呼び出すことができます。 |
AMQPシナリオ
Apache CXF
Apache CXFコンポーネント
Apache CXFシナリオ
Bean
Beanコンポーネント
cBean | [Repository] (リポジトリー)の [Code] (コード)ノードに保管されている、またはcBeanRegisterによって登録されているJava Beanを呼び出します。 |
cBeanRegister | メッセージ交換で使われるJava Beanをレジストリーに登録します。 |
CamelContext
CamelContextコンポーネント
cConfig | Javaコードを使ってCamelContextを設定します。 |
CamelContextシナリオ
Content Enricher
Content Enricherコンポーネント
cContentEnricher | コンシューマーまたはプロデューサーを使って、それぞれイベントメッセージングおよびリクエスト/応答メッセージングを目的とする追加データを取得します。 |
Content Enricherシナリオ
ConvertBody
ConvertBodyコンポーネント
cConvertBodyTo | メッセージボディを指定されたクラスタイプに変換します。 |
ConvertBodyシナリオ
Custom code
Custom codeコンポーネント
cJavaDSLProcessor | メッセージ交換のプロデューサーとコンシューマーを実装するか、Javaドメイン固有言語(DSL)を使ってメッセージトランスレーターを実装します。 |
cProcessor | メッセージ交換のコンシューマーを実装するか、メッセージトランスレーターを実装します。 |
Data Quality
Validation
Validationのコンポーネント
cJsonValidator | 特定のJSONスキーマに基づいてデータを検証します。 |
cXmlValidator | 特定のXMLスキーマに基づいてデータを検証します。 |
[Database] (データベース)
Databaseコンポーネント
cSQL | クエリーに基づき、SQL接続を使って任意のデータベースに対して読み書きを行います。 |
cSQLConnection | 指定したデータベースへの接続を開き、後続のサブジョブにも再利用できます。 |
Databaseのシナリオ
[Direct] (直接)
Directコンポーネント
Directシナリオ
Dynamic Router
Dynamic Routerコンポーネント
cDynamicRouter | 指定された条件で1つまたは複数のメッセージを異なるエンドポイントにルーティングします。 |
Dynamic Routerシナリオ
Exchange
Exchangeコンポーネント
cExchangePattern | ルートのメッセージ交換モードを設定します。 |
Exchangeシナリオ
[File] (ファイル)
Fileコンポーネント
cFile | ファイルシステムへのアクセスを提供し、他のコンポーネントによってファイルを処理したり、他のコンポーネントからのメッセージをディスクに保存したりできるようにします。 |
Fileシナリオ
Filter
Filterコンポーネント
cIdempotentConsumer | 既にレシーバーに送信されているメッセージを識別し、それらを除去します。メッセージは引き続き送信元によって送信されますが、配信段階ではレシーバーによって無視されます。 |
cMessageFilter | 指定された基準に従ってメッセージのコンテンツをフィルタリングし、フィルタリングされたメッセージを指定された出力チャネルにルーティングします。条件に一致しないメッセージはすべてドロップされます。 |
cMessageRouter | メッセージを後で新しい各チャネル内でより正確に処理できるように、フィルタリングされた各メッセージタイプに指定の条件に従って別々のチャネルを作成します。 |
cPipesAndFilters | メッセージルーティングを一連の独立した処理ステージに分割します。 |
Filterシナリオ
Flatpack
Flatpackコンポーネント
cFlatPack | FlatPackライブラリーを使って、固定幅または区切り付きファイルまたはメッセージを処理します |
Flatpackシナリオ
インターネット
Internetコンポーネント
Internetシナリオ
JMS
JMSのコンポーネント
cJMS | ルートとJMSプロバイダーの間でメッセージを交換します。 |
cMQConnectionFactory | MQサーバーに接続するための設定パラメーターのセットをカプセル化します。接続は、ルート内の複数のコンポーネントcJMS、cWMQ、cAMQP、またはcMQTTによって呼び出すことができます。 |
JMSシナリオ
JSON処理
JSON処理のコンポーネント
cJsonParser | JSON形式から目的のデータを抽出します。 |
cJsonWriter | 入力データをJSON形式に変換します。 |
JSON処理のシナリオ
Kafka
Kafkaコンポーネント
cKafka | Apache Kafkaメッセージブローカーと通信します。 |
Load Balancer
Load Balancerコンポーネント
cLoadBalancer | 負荷分散ポリシーに従って、受信したメッセージを複数のエンドポイントに配信します。 |
Load Balancerシナリオ
Logs and errors
Logs and errorsコンポーネント
cErrorHandler | メッセージルーティングのエラーを処理します。 |
cIntercept | 各メッセージサブルートをインターセプトし、元のサブルートを変更せずにそれを別のサブルートにリダイレクトします。この迂回が完了すると、元々意図されていたターゲットエンドポイントへのメッセージルーティングが続行されます。これは、テスト時にエラー処理をシミュレートするのに役立ちます。 |
cLog | ルートでメッセージ交換を記録します。 |
cOnException | 定義された例外をキャッチし、これらの例外とメッセージルーティングに対して実行される特定のアクションをトリガーします。 |
cTry | Try/Catch/Finallyブロックをビルドし、 エラーを生成する可能性が高いルートの部分を分離し、エラーをキャッチし、エラーに関係なく最終的な命令を実行することにより、Javaと同等の例外処理機能を提供します。 |
Logs and errorsシナリオ
Mailコンポーネント
cMail | ルートでメールを送受信します。 |
Mailシナリオ
マップ
Mapコンポーネント
cMap | パースペクティブにある の機能を利用して、異なる入力と出力の間で変換(マップと呼ばれる)を行います。 |
Mapシナリオ
Messaging Endpoint
Messaging Endpointコンポーネント
cMessagingEndpoin | 2つのアプリケーションに、メッセージを送信または受信することで通信することを許可します。 |
Messaging Endpointシナリオ
MQTT
MQTTのコンポーネント
cMQConnectionFactory | MQサーバーに接続するための設定パラメーターのセットをカプセル化します。接続は、ルート内の複数のコンポーネントcJMS、cWMQ、cAMQP、またはcMQTTによって呼び出すことができます。 |
cMQTT | MQTT準拠のメッセージブローカーにメッセージを送信するか、そこからメッセージを消費します。 |
MQTTシナリオ
Multicast
Multicastコンポーネント
cMulticast | メッセージを一度に複数のエンドポイントにルーティングし、別々の方法で処理します。 |
Multicastシナリオ
プロセス制御
Orchestrationコンポーネント
Orchestrationシナリオ
Recipient List
Recipient Listコンポーネント
cRecipientList | 動的に指定された複数の受信者にメッセージをルーティングします。 |
Recipient Listシナリオ
Route
Routeコンポーネント
cTalendJob | Data Integrationジョブとメディエーションルートの間でメッセージを交換します。 |
Routeシナリオ
Routing Slip
Routing Slipコンポーネント
cRoutingSlip | 一連の処理ステップを介してメッセージを連続的にルーティングします。一連のステップは設計時は不明であり、メッセージごとに可変です。 |
Routing Slipシナリオ
SEDA
SEDAコンポーネント
SEDAシナリオ
SetBody
SetBodyコンポーネント
cSetBody | ルートのメッセージボディを設定します。 |
SetBodyシナリオ
SetHeader
SetHeaderコンポーネント
cSetHeader | 後続のメッセージ処理のためにヘッダーに送信される各メッセージにヘッダーを設定するか、存在する場合はデフォルトのヘッダーをカスタマイズします。 |
SetHeaderシナリオ
SetProperty
SetPropertyコンポーネント
cSetProperty | 後続のメッセージ処理のために送信された各メッセージのプロパティを設定します。 |
Splitter
Splitterコンポーネント
cSplitter | メッセージをいくつかのサブメッセージに分割して、個別のルートで異なる方法で処理できるようにします。 |
Splitterシナリオ
Testing
Testingコンポーネント
Testingシナリオ
Throttler
Throttlerコンポーネント
cThrottler | 特定のエンドポイントが過負荷になるのを防ぐために、特定のエンドポイントに流れるメッセージの数を制限します。 |
Throttlerシナリオ
Wiretap
Wiretapコンポーネント
cWireTap | メッセージが元のエンドポイントに送信されている間に、メッセージをユーザー定義のURIにワイヤータップします。また、cWireTapを使うと、新しいメッセージをこのワイヤータップURIに同時に入力できます。 |
Wiretapシナリオ
WMQ
WMQコンポーネント
cMQConnectionFactory | MQサーバーに接続するための設定パラメーターのセットをカプセル化します。接続は、ルート内の複数のコンポーネントcJMS、cWMQ、cAMQP、またはcMQTTによって呼び出すことができます。 |
cWMQ | WMQを使ってルートとJMSプロバイダーの間でメッセージを交換します。 |
XML処理
XML処理のコンポーネント
cXmlParser | XML形式から目的のデータを抽出します。 |
cXmlWriter | 入力データをXML形式に変換します。 |