Skip to content

Commit 24ce4a3

Browse files
sdk-teamsdk-team
committed
Generated java-async 2022-08-01 for RocketMQ.
1 parent a72cf16 commit 24ce4a3

13 files changed

+2582
-1
lines changed

‎rocketmq-20220801/ChangeLog.txt‎

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,6 @@
1+
2025-09-23 Version: 4.0.1
2+
- Generated java-async 2022-08-01 for RocketMQ.
3+
14
2025-08-15 Version: 4.0.0
25
- Generated java-async 2022-08-01 for RocketMQ.
36

‎rocketmq-20220801/pom.xml‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@
33
<modelVersion>4.0.0</modelVersion>
44
<groupId>com.aliyun</groupId>
55
<artifactId>alibabacloud-rocketmq20220801</artifactId>
6-
<version>4.0.0</version>
6+
<version>4.0.1</version>
77
<packaging>jar</packaging>
88
<name>alibabacloud-rocketmq20220801</name>
99
<description>Alibaba Cloud RocketMQ (20220801) Async SDK for Java

‎rocketmq-20220801/src/main/java/com/aliyun/sdk/service/rocketmq20220801/AsyncClient.java‎

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -159,6 +159,18 @@ static AsyncClient create() {
159159
*/
160160
CompletableFuture<DeleteTopicResponse> deleteTopic(DeleteTopicRequest request);
161161

162+
/**
163+
* @param request the request parameters of ExecuteMigrationOperation ExecuteMigrationOperationRequest
164+
* @return ExecuteMigrationOperationResponse
165+
*/
166+
CompletableFuture<ExecuteMigrationOperationResponse> executeMigrationOperation(ExecuteMigrationOperationRequest request);
167+
168+
/**
169+
* @param request the request parameters of FinishMigrationStage FinishMigrationStageRequest
170+
* @return FinishMigrationStageResponse
171+
*/
172+
CompletableFuture<FinishMigrationStageResponse> finishMigrationStage(FinishMigrationStageRequest request);
173+
162174
/**
163175
* <b>description</b> :
164176
* <blockquote>
@@ -335,6 +347,12 @@ static AsyncClient create() {
335347
*/
336348
CompletableFuture<ListMetricMetaResponse> listMetricMeta(ListMetricMetaRequest request);
337349

350+
/**
351+
* @param request the request parameters of ListMigrationOperations ListMigrationOperationsRequest
352+
* @return ListMigrationOperationsResponse
353+
*/
354+
CompletableFuture<ListMigrationOperationsResponse> listMigrationOperations(ListMigrationOperationsRequest request);
355+
338356
/**
339357
* @param request the request parameters of ListRegions ListRegionsRequest
340358
* @return ListRegionsResponse

‎rocketmq-20220801/src/main/java/com/aliyun/sdk/service/rocketmq20220801/DefaultAsyncClient.java‎

Lines changed: 54 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -395,6 +395,42 @@ public CompletableFuture<DeleteTopicResponse> deleteTopic(DeleteTopicRequest req
395395
}
396396
}
397397

398+
/**
399+
* @param request the request parameters of ExecuteMigrationOperation ExecuteMigrationOperationRequest
400+
* @return ExecuteMigrationOperationResponse
401+
*/
402+
@Override
403+
public CompletableFuture<ExecuteMigrationOperationResponse> executeMigrationOperation(ExecuteMigrationOperationRequest request) {
404+
try {
405+
this.handler.validateRequestModel(request);
406+
TeaRequest teaRequest = REQUEST.copy().setStyle(RequestStyle.RESTFUL).setAction("ExecuteMigrationOperation").setMethod(HttpMethod.POST).setPathRegex("/migrations/{migrationId}/stages/{stageType}/operations/{operationId}/execute").setBodyType(BodyType.JSON).setBodyIsForm(false).setReqBodyType(BodyType.JSON).formModel(request);
407+
ClientExecutionParams params = new ClientExecutionParams().withInput(request).withRequest(teaRequest).withOutput(ExecuteMigrationOperationResponse.create());
408+
return this.handler.execute(params);
409+
} catch (Exception e) {
410+
CompletableFuture<ExecuteMigrationOperationResponse> future = new CompletableFuture<>();
411+
future.completeExceptionally(e);
412+
return future;
413+
}
414+
}
415+
416+
/**
417+
* @param request the request parameters of FinishMigrationStage FinishMigrationStageRequest
418+
* @return FinishMigrationStageResponse
419+
*/
420+
@Override
421+
public CompletableFuture<FinishMigrationStageResponse> finishMigrationStage(FinishMigrationStageRequest request) {
422+
try {
423+
this.handler.validateRequestModel(request);
424+
TeaRequest teaRequest = REQUEST.copy().setStyle(RequestStyle.RESTFUL).setAction("FinishMigrationStage").setMethod(HttpMethod.POST).setPathRegex("/migrations/{migrationId}/stages/{stageType}/finish").setBodyType(BodyType.JSON).setBodyIsForm(false).setReqBodyType(BodyType.JSON).formModel(request);
425+
ClientExecutionParams params = new ClientExecutionParams().withInput(request).withRequest(teaRequest).withOutput(FinishMigrationStageResponse.create());
426+
return this.handler.execute(params);
427+
} catch (Exception e) {
428+
CompletableFuture<FinishMigrationStageResponse> future = new CompletableFuture<>();
429+
future.completeExceptionally(e);
430+
return future;
431+
}
432+
}
433+
398434
/**
399435
* <b>description</b> :
400436
* <blockquote>
@@ -883,6 +919,24 @@ public CompletableFuture<ListMetricMetaResponse> listMetricMeta(ListMetricMetaRe
883919
}
884920
}
885921

922+
/**
923+
* @param request the request parameters of ListMigrationOperations ListMigrationOperationsRequest
924+
* @return ListMigrationOperationsResponse
925+
*/
926+
@Override
927+
public CompletableFuture<ListMigrationOperationsResponse> listMigrationOperations(ListMigrationOperationsRequest request) {
928+
try {
929+
this.handler.validateRequestModel(request);
930+
TeaRequest teaRequest = REQUEST.copy().setStyle(RequestStyle.RESTFUL).setAction("ListMigrationOperations").setMethod(HttpMethod.GET).setPathRegex("/migrations/{migrationId}/stages/{stageType}/operations").setBodyType(BodyType.JSON).setBodyIsForm(false).setReqBodyType(BodyType.JSON).formModel(request);
931+
ClientExecutionParams params = new ClientExecutionParams().withInput(request).withRequest(teaRequest).withOutput(ListMigrationOperationsResponse.create());
932+
return this.handler.execute(params);
933+
} catch (Exception e) {
934+
CompletableFuture<ListMigrationOperationsResponse> future = new CompletableFuture<>();
935+
future.completeExceptionally(e);
936+
return future;
937+
}
938+
}
939+
886940
/**
887941
* @param request the request parameters of ListRegions ListRegionsRequest
888942
* @return ListRegionsResponse

‎rocketmq-20220801/src/main/java/com/aliyun/sdk/service/rocketmq20220801/models/ExecuteMigrationOperationRequest.java‎

Lines changed: 235 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,235 @@
1+
// This file is auto-generated, don't edit it. Thanks.
2+
package com.aliyun.sdk.service.rocketmq20220801.models;
3+
4+
import com.aliyun.sdk.gateway.pop.*;
5+
import darabonba.core.*;
6+
import darabonba.core.async.*;
7+
import darabonba.core.sync.*;
8+
import darabonba.core.client.*;
9+
import darabonba.core.RequestModel;
10+
import darabonba.core.TeaModel;
11+
import com.aliyun.sdk.gateway.pop.models.*;
12+
13+
/**
14+
*
15+
* {@link ExecuteMigrationOperationRequest} extends {@link RequestModel}
16+
*
17+
* <p>ExecuteMigrationOperationRequest</p>
18+
*/
19+
public class ExecuteMigrationOperationRequest extends Request {
20+
@com.aliyun.core.annotation.Path
21+
@com.aliyun.core.annotation.NameInMap("migrationId")
22+
@com.aliyun.core.annotation.Validation(required = true)
23+
private Long migrationId;
24+
25+
@com.aliyun.core.annotation.Path
26+
@com.aliyun.core.annotation.NameInMap("stageType")
27+
@com.aliyun.core.annotation.Validation(required = true)
28+
private String stageType;
29+
30+
@com.aliyun.core.annotation.Path
31+
@com.aliyun.core.annotation.NameInMap("operationId")
32+
@com.aliyun.core.annotation.Validation(required = true)
33+
private Long operationId;
34+
35+
@com.aliyun.core.annotation.Body
36+
@com.aliyun.core.annotation.NameInMap("operationParam")
37+
private OperationParam operationParam;
38+
39+
@com.aliyun.core.annotation.Query
40+
@com.aliyun.core.annotation.NameInMap("instanceId")
41+
private String instanceId;
42+
43+
private ExecuteMigrationOperationRequest(Builder builder) {
44+
super(builder);
45+
this.migrationId = builder.migrationId;
46+
this.stageType = builder.stageType;
47+
this.operationId = builder.operationId;
48+
this.operationParam = builder.operationParam;
49+
this.instanceId = builder.instanceId;
50+
}
51+
52+
public static Builder builder() {
53+
return new Builder();
54+
}
55+
56+
public static ExecuteMigrationOperationRequest create() {
57+
return builder().build();
58+
}
59+
60+
@Override
61+
public Builder toBuilder() {
62+
return new Builder(this);
63+
}
64+
65+
/**
66+
* @return migrationId
67+
*/
68+
public Long getMigrationId() {
69+
return this.migrationId;
70+
}
71+
72+
/**
73+
* @return stageType
74+
*/
75+
public String getStageType() {
76+
return this.stageType;
77+
}
78+
79+
/**
80+
* @return operationId
81+
*/
82+
public Long getOperationId() {
83+
return this.operationId;
84+
}
85+
86+
/**
87+
* @return operationParam
88+
*/
89+
public OperationParam getOperationParam() {
90+
return this.operationParam;
91+
}
92+
93+
/**
94+
* @return instanceId
95+
*/
96+
public String getInstanceId() {
97+
return this.instanceId;
98+
}
99+
100+
public static final class Builder extends Request.Builder<ExecuteMigrationOperationRequest, Builder> {
101+
private Long migrationId;
102+
private String stageType;
103+
private Long operationId;
104+
private OperationParam operationParam;
105+
private String instanceId;
106+
107+
private Builder() {
108+
super();
109+
}
110+
111+
private Builder(ExecuteMigrationOperationRequest request) {
112+
super(request);
113+
this.migrationId = request.migrationId;
114+
this.stageType = request.stageType;
115+
this.operationId = request.operationId;
116+
this.operationParam = request.operationParam;
117+
this.instanceId = request.instanceId;
118+
}
119+
120+
/**
121+
* <p>This parameter is required.</p>
122+
*
123+
* <strong>example:</strong>
124+
* <p>44</p>
125+
*/
126+
public Builder migrationId(Long migrationId) {
127+
this.putPathParameter("migrationId", migrationId);
128+
this.migrationId = migrationId;
129+
return this;
130+
}
131+
132+
/**
133+
* <p>This parameter is required.</p>
134+
*
135+
* <strong>example:</strong>
136+
* <p>MIGRATE_METADATA</p>
137+
*/
138+
public Builder stageType(String stageType) {
139+
this.putPathParameter("stageType", stageType);
140+
this.stageType = stageType;
141+
return this;
142+
}
143+
144+
/**
145+
* <p>This parameter is required.</p>
146+
*
147+
* <strong>example:</strong>
148+
* <p>2729</p>
149+
*/
150+
public Builder operationId(Long operationId) {
151+
this.putPathParameter("operationId", operationId);
152+
this.operationId = operationId;
153+
return this;
154+
}
155+
156+
/**
157+
* operationParam.
158+
*/
159+
public Builder operationParam(OperationParam operationParam) {
160+
this.putBodyParameter("operationParam", operationParam);
161+
this.operationParam = operationParam;
162+
return this;
163+
}
164+
165+
/**
166+
* instanceId.
167+
*/
168+
public Builder instanceId(String instanceId) {
169+
this.putQueryParameter("instanceId", instanceId);
170+
this.instanceId = instanceId;
171+
return this;
172+
}
173+
174+
@Override
175+
public ExecuteMigrationOperationRequest build() {
176+
return new ExecuteMigrationOperationRequest(this);
177+
}
178+
179+
}
180+
181+
/**
182+
*
183+
* {@link ExecuteMigrationOperationRequest} extends {@link TeaModel}
184+
*
185+
* <p>ExecuteMigrationOperationRequest</p>
186+
*/
187+
public static class OperationParam extends TeaModel {
188+
@com.aliyun.core.annotation.NameInMap("paramData")
189+
private Object paramData;
190+
191+
private OperationParam(Builder builder) {
192+
this.paramData = builder.paramData;
193+
}
194+
195+
public static Builder builder() {
196+
return new Builder();
197+
}
198+
199+
public static OperationParam create() {
200+
return builder().build();
201+
}
202+
203+
/**
204+
* @return paramData
205+
*/
206+
public Object getParamData() {
207+
return this.paramData;
208+
}
209+
210+
public static final class Builder {
211+
private Object paramData;
212+
213+
private Builder() {
214+
}
215+
216+
private Builder(OperationParam model) {
217+
this.paramData = model.paramData;
218+
}
219+
220+
/**
221+
* paramData.
222+
*/
223+
public Builder paramData(Object paramData) {
224+
this.paramData = paramData;
225+
return this;
226+
}
227+
228+
public OperationParam build() {
229+
return new OperationParam(this);
230+
}
231+
232+
}
233+
234+
}
235+
}

0 commit comments

Comments
 (0)