com.infoteria.asteria.flowengine2.thinclient
Class FlowAdminClient

java.lang.Object
  |
  +--com.infoteria.asteria.flowengine2.thinclient.AsteriaClient
        |
        +--com.infoteria.asteria.flowengine2.thinclient.FlowAdminClient

public class FlowAdminClient

extends AsteriaClient

リクエストの取得や強制終了を行うためのクライアントクラスです。

Fields inherited from class com.infoteria.asteria.flowengine2.thinclient.AsteriaClient

_sessionId

Constructor Summary

FlowAdminClient(AsteriaClient client)
別のASTERIAクライアントから接続先情報とログイン状態を引き継いでクライアントを作成します。

FlowAdminClient(String url)
ASTERIAサーバーのURLを指定してクライアントを作成します。
特に変更していない場合、URLは「http://<SERVERNAME>:21381/flow-rpc」となります。

FlowAdminClient(String server, int port)
ASTERIAサーバーのサーバー名とポート番号を指定してクライアントを作成します。

Method Summary

RequestInfo[]	getRequestList() リクエスト一覧を取得します。
CheckPointInfo[]	getRequestWithCheckPoint(String yyyyMMdd, String requestId, String serverId, String ownerDomain, String ownerName, String project, String flow, String checkPointStatus, String requestStatus, String sortKey, int start, int size) チェックポイントフローのリクエストの一覧を取得します。
ServerInfo[]	getServerList() サーバー一覧を取得します。
RequestInfo[]	getWorkerList() ワーカー一覧を取得します。
String	killRequest(String requestId) リクエストを強制終了します
RunningStatus	showRequest(String requestId) 実行中のリクエストの状態を取得します。

Methods inherited from class com.infoteria.asteria.flowengine2.thinclient.AsteriaClient

login, login, logout, releaseSession

Methods inherited from class java.lang.Object

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

Constructor Detail

FlowAdminClient

public FlowAdminClient(String url)
                throws MalformedURLException

ASTERIAサーバーのURLを指定してクライアントを作成します。
特に変更していない場合、URLは「http://<SERVERNAME>:21381/flow-rpc」となります。

FlowAdminClient

public FlowAdminClient(String server,
                       int port)
                throws MalformedURLException

ASTERIAサーバーのサーバー名とポート番号を指定してクライアントを作成します。

Parameters:

server - サーバー名またはIPアドレス

port - ポート番号

FlowAdminClient

public FlowAdminClient(AsteriaClient client)

別のASTERIAクライアントから接続先情報とログイン状態を引き継いでクライアントを作成します。

Parameters:

client - ログイン済みのAsteriaClient

Method Detail

getRequestList

public RequestInfo[] getRequestList()
                             throws FlowClientException

リクエスト一覧を取得します。

Returns:

リクエスト情報の配列

getWorkerList

public RequestInfo[] getWorkerList()
                            throws FlowClientException

ワーカー一覧を取得します。

Returns:

リクエスト情報の配列

showRequest

public RunningStatus showRequest(String requestId)
                          throws FlowClientException

実行中のリクエストの状態を取得します。

Parameters:

requestId - リクエストID

Returns:

実行情報

killRequest

public String killRequest(String requestId)
                   throws FlowClientException

リクエストを強制終了します

Parameters:

requestId - リクエストID

Returns:

強制終了に成功した場合に最後に実行したコンポーネントのフルネーム

getRequestWithCheckPoint

public CheckPointInfo[] getRequestWithCheckPoint(String yyyyMMdd,
                                                 String requestId,
                                                 String serverId,
                                                 String ownerDomain,
                                                 String ownerName,
                                                 String project,
                                                 String flow,
                                                 String checkPointStatus,
                                                 String requestStatus,
                                                 String sortKey,
                                                 int start,
                                                 int size)
                                          throws FlowClientException

チェックポイントフローのリクエストの一覧を取得します。

Parameters:

yyyyMMdd - 年月日

requestId - リクエストID

serverId - 担当サーバーID

ownerDomain - プロジェクトオーナーdomain

ownerName - プロジェクトオーナーname

project - プロジェクト名

flow - フロー名

checkPointStatus - チェックポイントステータス

requestStatus - リクエストステータス

sortKey - ソートキー

start - 開始番号

size - リスト数

Returns:

チェックポイント情報の配列

getServerList

public ServerInfo[] getServerList()
                           throws FlowClientException

サーバー一覧を取得します。

Returns:

サーバー情報の配列