2017-08-03 7 views
1

こんにちは、私は、Apacheラクダで作業を開始だし、それが可能このようラクダを使用する場合、私は疑問に思う:ビーン方法

一部のサービス(豆):

public class SomeService { 
    public Future<Data> someMethod() { 
     //Do async job 
    } 
} 

RouteBuilder擬似構成:

public class MyRouteBuilder extends RouteBuilder { 
    SomeService someService; //injected instance 

    public void configure() { 
     from("source.route") 
      .bean(someService, "someMethod") 
      .to("destination.route.after.job.started") 
      .afterTo("destination.route.after.job.finished") //afterTo is a concept 
     .end() 
    } 
} 

だからdestination.route.after.job.startedが直後に到達しますが返されました。 destination.route.after.job.finishedは、非同期ジョブが完了した後に到達します。

答えて

0

は、cookbookの説明のとおり使用できます。使用方法は次のようになります。

from("file:data/in").process(new MyValidator()).threads(20) 
.process(new MyTransformation()).to("jpa:PurchaseOrder"); 

詳細については、クックブックを参照してください。

関連する問題