MPS サービスを開始すると、システムは自動的に MPS キューを作成します。 インターフェイスを使用して MPS キュー (パイプライン) を管理することもできます。 たとえば、SearchPipeline、QueryPipelineList や UpdatePipeline などがあります。
MPS キューの検索
SearchPipeline インターフェイスを使用して、MPS キュー情報を検索します。
String region = "<region>";
String accessKeyId = "<accessKeyId>";
String accessKeySecret = "<accessKeySecret>";
DefaultProfile profile = DefaultProfile.getProfile(region, accessKeyId, accessKeySecret);
DefaultAcsClient client = new DefaultAcsClient(profile);
SearchPipelineRequest request = new SearchPipelineRequest();
// If an error occurs, it can throw ClientException or ServerException.
SearchPipelineResponse response = client.getAcsResponse(request);
List<SearchPipelineResponse.Pipeline> pipelines = response.getPipelineList();
for (SearchPipelineResponse.Pipeline pipeline : pipelines) {
System.out.println("pipeline id:" + pipeline.getId() + ", name:" + pipeline.getName() + ", state:" + pipeline.getState());
}
MPS キューの照会
pipelineId がわかっている場合は、pipelineId を使用することで QueryPipelineList インターフェイスを呼び出し、 MPS キュー情報を照会することができます。
String region = "<region>";
String accessKeyId = "<accessKeyId>";
String accessKeySecret = "<accessKeySecret>";
// known pipeline ID, seperated by comma (,)
String pipelineIds = "<pipelineIds>";
DefaultProfile profile = DefaultProfile.getProfile(region, accessKeyId, accessKeySecret);
IAcsClient client = new DefaultAcsClient(profile);
QueryPipelineListRequest request = new QueryPipelineListRequest();
request.setPipelineIds(pipelineId);
//If an error occurs, it can throw ClientException or ServerException
QueryPipelineListResponse response = client.getAcsResponse(request);
List<QueryPipelineListResponse.Pipeline> pipelines = response.getPipelineList();
for (QueryPipelineListResponse.Pipeline pipeline : pipelines) {
System.out.println("pipeline id:" + pipeline.getId() + ", name:" + pipeline.getName() + ", state:" + pipeline.getState());
}
MPS キューの更新
UpdatePipeline インターフェイスを使用して、 MPS キューの名前やステータスなどの MPS キュー情報を更新します。 ステータスには Active や Paused があります。
String region = "<region>";
String accessKeyId = "<accessKeyId>";
String accessKeySecret = "<accessKeySecret>";
DefaultProfile profile = DefaultProfile.getProfile(region, accessKeyId, accessKeySecret);
DefaultAcsClient client = new DefaultAcsClient(profile);
// Search user pipeline, the number is one by default.
SearchPipelineRequest searchPipelineRequest = new SearchPipelineRequest();
// If an error occurs, it can throw ClientException or ServerException.
SearchPipelineResponse searchPipelineResponse = client.getAcsResponse(searchPipelineRequest);
List<SearchPipelineResponse.Pipeline> pipelines = searchPipelineResponse.getPipelineList();
SearchPipelineResponse.Pipeline queryPipeline = pipelines.get(0);
//Update MPS queue status
UpdatePipelineRequest request = new UpdatePipelineRequest();
request.setPipelineId(queryPipeline.getId());
request.setState("Paused");
request.setName(queryPipeline.getName());
//If an error occurs, it can throw ClientException.
UpdatePipelineResponse response = client.getAcsResponse(request);
UpdatePipelineResponse.Pipeline pipeline = response.getPipeline();
System.out.println("pipeline id:" + pipeline.getId() + ", name:" + pipeline.getName() + ", state:" + pipeline.getState());