jp.go.nict.isp.wrapper.wisdom.abstractservice

Class WorkerExecutor<V>

java.lang.Object

jp.go.nict.isp.wrapper.wisdom.abstractservice.WorkerExecutor<V>

public class WorkerExecutor<V>
extends Object

WorkerExecutorクラス.
サービス連携フレームワークで、ワーカーとの連携を実装するクラス.
ワーカーへのリクエスト制御や結果の管理及び連携を制御する.

Constructor Summary

Constructors

Constructor and Description
WorkerExecutor() コンストラクタ

Method Summary

Modifier and Type	Method and Description
<S> void	execute(boolean isStreamingReady, jp.go.nict.langrid.servicecontainer.executor.StreamingReceiver<Object> resultReceiver, ClientFactory clfactory, Class<S> clsService, int waitTimeOut, AbstractServerModule<V,S> serverModule, ResultStorage<V> resultStorage, List<String> defEndpoints, EndpointFactory ef) サービス連携実行処理

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

WorkerExecutor

public WorkerExecutor()

コンストラクタ

Method Detail

execute

public final <S> void execute(boolean isStreamingReady,
                              jp.go.nict.langrid.servicecontainer.executor.StreamingReceiver<Object> resultReceiver,
                              ClientFactory clfactory,
                              Class<S> clsService,
                              int waitTimeOut,
                              AbstractServerModule<V,S> serverModule,
                              ResultStorage<V> resultStorage,
                              List<String> defEndpoints,
                              EndpointFactory ef)
                       throws ProcessFailedException

サービス連携実行処理

Parameters:

isStreamingReady - ストリーミングフラグ

resultReceiver - 結果通知用レシーバ

clfactory - クライアントファクトリー

clsService - サービスクラス

waitTimeOut - タイムアウト値

serverModule - サーバーモジュールオブジェクト

services - msgpack用サービスマッピング

resultStorage - 結果格納ストレージ

defEndpoints - デフォルトのエンドポイントリスト

ef - エンドポイントファクトリー

Throws:

ProcessFailedException