CamelがさまざまなURIタイプを扱えるようにしましょう。

Question

URI（http、ftp、file ...など）を取得し、データをフェッチしてファイルにローカルに格納するCamel Routeを作成したいと考えています。

このURI-文字列には、例えば、次のようになります。

• "ftp://localhost/example.txt"
• "ファイル：//tmp/example.txt"
• "のJMS：キュー：dataInputQueue"
• ...

この文字列に基づいて、正しいCamelコンポーネントを使用してデータにアクセスする必要があります。/Javaで切り替える場合のようなもの：

（1）URI（URI = "VM：incomingUri" から）を受信

（2） "右" キャメルコンポーネント

switch(URI) 
case HTTP: use Camel HTTP component 
case FTP: use Camel FTP component 
case JMS: use Camel JMS component 
... 

（3を選んだがincomingUri "：VM」から ：// ...）

例ファイル"）のuri =に（ローカル "右" キャメルコンポーネント

（4）ストアファイルを使用して、そのURIからデータを読みます私は文字列 "ftp://localhost/example.txt"。最終的に何が起こる必要があるのか​​は、これと同じでなければなりません。

<route> 
    <from uri="ftp://localhost/example.txt"/> 
    <to uri="file://tmpDir/example.txt"/> 
</route> 

これはCamelのようにどのように見えますか？

Answer 1

それは

<to uri="{{some.endpoint}}"/> 

を使用することにより可能である。しかし、あなたは、プロパティにそれを追加することが必要となります。

<cm:property name="some.endpoint" value="SomeEndPoint"/> 

そして、あなたはSomeEndPointの

値の任意のVMなど、JMS、ログ、ファイル、FTP、HTTPをしたいエンドポイントを追加することができます。

1. ログインコンポーネント：ログ：モック

2. JMSコンポーネント：のActiveMQ：someQueueName

3. ファイルコンポーネント：ファイル：// someFileShare

4. VMComponent： vm：toSomeRoute

Answer 2

私は1つの難易度はあなたが言及コンポーネント（HTTP、FTP、ファイル、JMS）のために、あなたがプロデューサまたはコンシューマのいずれかを使用することをお勧めします、ということになると信じて：

• FTP 、File：間違いなくファイルを読む消費者。
• 間違いなく、プロデューサーがサーバーに要求を送信します（サーバーの返信は新しいメッセージ本文で行われます）
• JMS：キュー（消費者）から読み込みたいReplyToヘッダー付きのキューにメッセージを送信してから、応答（プロデューサ）を待ちます。

プロデューサー：

あなたが2.16+キャメルを使用している場合は、新しい"dynamic to"構文を使用することができます。エンドポイントuriがsimple式（またはoptionnaly、別のタイプの式）を使用して動的に評価できる点を除いて、基本的には "to"と同じです。また、のenrichフレーバーを使用できます。また、Camel 2.16以降の動的なウイスもサポートしています。

旧バージョンのCamelを使用している場合、または複数のエンドポイント（1つではない）に動的にルーティングする必要がある場合は、recipient listパターンを使用できます。

ここに例があります。エンドポイントを呼び出すことによってメッセージ本文を変換します。そのエンドポイントのURIはTargetUriというヘッダーにあり、メッセージごとに動的に評価されます。

// An instance of this class is registered as 'testbean' in the registry. Instead of 
// sending to this bean, I could send to a FTP or HTTP endpoint, or whatever. 
public class TestBean { 
    public String toUpperCase(final String str) { 
     return str.toUpperCase(); 
    } 
} 

// This route sends a message to our example route for testing purpose. Of course, we 
// could send any message as long as the 'TargetUri' header contains a valid endpoint uri 
from("file:inbox?move=done&moveFailed=failed") 
.setHeader("TargetUri").constant("bean:testbean?method=toUpperCase") 
.setBody().constant("foo") 
.to("direct:test"); 

// 1. The toD example : 
from("direct:test") 
.toD("${header.TargetUri}") 
.to("log:myRoute"); 

// 2. The recipient list example : 
from("direct:test") 
.recipientList(header("TargetUri")) 
.to("log:myRoute"); 

// 3. The enrich example : 
from("direct:test") 
.enrich().simple("${header.TargetUri}") // add an AggregationStrategy if necessary 
.to("log:myRoute"); 

消費者：

キャメル2.16+で、あなたはcontent-enricher patternのpollEnrich風味を使用することができます。

旧バージョンのCamelでは、プロセッサーにConsumerTemplateを使用できます。

// 4. The pollEnrich example (assuming the TargetUri header contains, e.g., a file 
// or ftp uri) : 
from("direct:test") 
.pollEnrich().simple("${header.TargetUri}") // add an AggregationStrategy if necessary 
.to("log:myRoute"); 

// 5. The ConsumerTemplate example (same assumption as above) 
from("direct:test") 
.process(new Processor() { 
    @Override 
    public void process(Exchange exchange) throws Exception { 
     String uri = exchange.getIn().getHeader("TargetUri", String.class); 
     ConsumerTemplate consumer = exchange.getContext().createConsumerTemplate(); 
     final Object data = consumer.receiveBody(uri); 
     exchange.getIn().setBody(data); 
    } 
}) 
.to("log:myRoute"); 

プロデューサまたはコンシューマ？

悲しいことに、私はどちらも本当に優雅な解決策を考えることはできません - 私はあなたがuriと既知のコンポーネントに基づいて2つの支店にルーティングする必要があると思う...ここでは、キャメル2.16+）と、それは非常にきれいではありません。

// This example only handles http and ftp endpoints properly 
from("direct:test") 
.choice() 
    .when(header("TargetUri").startsWith("http")) 
     .enrich().simple("${header.TargetUri}") 
    .endChoice() 
    .when(header("TargetUri").startsWith("ftp")) 
     .pollEnrich().simple("${header.TargetUri}") 
    .endChoice() 
.end() 
.to("log:myRoute");