Skip to content

Commit aa7e89e

Browse files
author
BitsAdmin
committed
Merge branch 'rocketmq-Java-2023-01-01-online-698-2024_10_22_11_10_45' into 'integration_2024-10-24_515996570370'
feat: [development task] rocketmq-698-java (818777) See merge request iaasng/volcengine-java-sdk!274
2 parents 29ff2ed + d71987b commit aa7e89e

File tree

153 files changed

+29915
-0
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

153 files changed

+29915
-0
lines changed

‎pom.xml‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -248,5 +248,6 @@
248248
<module>volcengine-java-sdk-sts</module>
249249
<module>volcengine-java-sdk-kms</module>
250250
<module>volcengine-java-sdk-nta</module>
251+
<module>volcengine-java-sdk-rocketmq</module>
251252
</modules>
252253
</project>

‎volcengine-java-sdk-bom/pom.xml‎

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -253,6 +253,12 @@
253253
<optional>false</optional>
254254
<version>${project.version}</version>
255255
</dependency>
256+
<dependency>
257+
<groupId>com.volcengine</groupId>
258+
<artifactId>volcengine-java-sdk-rocketmq</artifactId>
259+
<optional>false</optional>
260+
<version>${project.version}</version>
261+
</dependency>
256262
</dependencies>
257263
</dependencyManagement>
258264
</project>

‎volcengine-java-sdk-rocketmq/pom.xml‎

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
3+
<parent>
4+
<artifactId>volcengine-java-sdk</artifactId>
5+
<groupId>com.volcengine</groupId>
6+
<version>0.1.133</version>
7+
<relativePath>../pom.xml</relativePath>
8+
</parent>
9+
<modelVersion>4.0.0</modelVersion>
10+
<artifactId>volcengine-java-sdk-rocketmq</artifactId>
11+
<dependencies>
12+
<dependency>
13+
<groupId>com.volcengine</groupId>
14+
<artifactId>volcengine-java-sdk-core</artifactId>
15+
<version>${project.version}</version>
16+
</dependency>
17+
</dependencies>
18+
<build>
19+
<plugins>
20+
<plugin>
21+
<groupId>org.apache.maven.plugins</groupId>
22+
<artifactId>maven-source-plugin</artifactId>
23+
<configuration>
24+
<excludes>
25+
<exclude>com/volcengine/rocketmq/examples/**</exclude>
26+
</excludes>
27+
</configuration>
28+
</plugin>
29+
<plugin>
30+
<groupId>org.apache.maven.plugins</groupId>
31+
<artifactId>maven-jar-plugin</artifactId>
32+
<configuration>
33+
<excludes>
34+
<exclude>com/volcengine/rocketmq/examples/**</exclude>
35+
</excludes>
36+
</configuration>
37+
</plugin>
38+
</plugins>
39+
</build>
40+
</project>

‎volcengine-java-sdk-rocketmq/src/main/java/com/volcengine/rocketmq/RocketmqApi.java‎

Lines changed: 7112 additions & 0 deletions
Large diffs are not rendered by default.

‎volcengine-java-sdk-rocketmq/src/main/java/com/volcengine/rocketmq/model/AccessKeysInfoForDescribeAccessKeysOutput.java‎

Lines changed: 209 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,209 @@
1+
/*
2+
* rocketmq
3+
* No description provided (generated by Swagger Codegen https://github.com/swagger-api/swagger-codegen)
4+
*
5+
* OpenAPI spec version: common-version
6+
*
7+
*
8+
* NOTE: This class is auto generated by the swagger code generator program.
9+
* https://github.com/swagger-api/swagger-codegen.git
10+
* Do not edit the class manually.
11+
*/
12+
13+
package com.volcengine.rocketmq.model;
14+
15+
import java.util.Objects;
16+
import java.util.Arrays;
17+
import com.google.gson.TypeAdapter;
18+
import com.google.gson.annotations.JsonAdapter;
19+
import com.google.gson.annotations.SerializedName;
20+
import com.google.gson.stream.JsonReader;
21+
import com.google.gson.stream.JsonWriter;
22+
import io.swagger.v3.oas.annotations.media.Schema;
23+
import java.io.IOException;
24+
import javax.validation.constraints.*;
25+
import javax.validation.Valid;
26+
/**
27+
* AccessKeysInfoForDescribeAccessKeysOutput
28+
*/
29+
30+
31+
32+
public class AccessKeysInfoForDescribeAccessKeysOutput {
33+
@SerializedName("AccessKey")
34+
private String accessKey = null;
35+
36+
@SerializedName("AclConfigJson")
37+
private String aclConfigJson = null;
38+
39+
@SerializedName("Actived")
40+
private Boolean actived = null;
41+
42+
@SerializedName("AllAuthority")
43+
private String allAuthority = null;
44+
45+
@SerializedName("CreateTime")
46+
private String createTime = null;
47+
48+
@SerializedName("Description")
49+
private String description = null;
50+
51+
public AccessKeysInfoForDescribeAccessKeysOutput accessKey(String accessKey) {
52+
this.accessKey = accessKey;
53+
return this;
54+
}
55+
56+
/**
57+
* Get accessKey
58+
* @return accessKey
59+
**/
60+
@Schema(description = "")
61+
public String getAccessKey() {
62+
return accessKey;
63+
}
64+
65+
public void setAccessKey(String accessKey) {
66+
this.accessKey = accessKey;
67+
}
68+
69+
public AccessKeysInfoForDescribeAccessKeysOutput aclConfigJson(String aclConfigJson) {
70+
this.aclConfigJson = aclConfigJson;
71+
return this;
72+
}
73+
74+
/**
75+
* Get aclConfigJson
76+
* @return aclConfigJson
77+
**/
78+
@Schema(description = "")
79+
public String getAclConfigJson() {
80+
return aclConfigJson;
81+
}
82+
83+
public void setAclConfigJson(String aclConfigJson) {
84+
this.aclConfigJson = aclConfigJson;
85+
}
86+
87+
public AccessKeysInfoForDescribeAccessKeysOutput actived(Boolean actived) {
88+
this.actived = actived;
89+
return this;
90+
}
91+
92+
/**
93+
* Get actived
94+
* @return actived
95+
**/
96+
@Schema(description = "")
97+
public Boolean isActived() {
98+
return actived;
99+
}
100+
101+
public void setActived(Boolean actived) {
102+
this.actived = actived;
103+
}
104+
105+
public AccessKeysInfoForDescribeAccessKeysOutput allAuthority(String allAuthority) {
106+
this.allAuthority = allAuthority;
107+
return this;
108+
}
109+
110+
/**
111+
* Get allAuthority
112+
* @return allAuthority
113+
**/
114+
@Schema(description = "")
115+
public String getAllAuthority() {
116+
return allAuthority;
117+
}
118+
119+
public void setAllAuthority(String allAuthority) {
120+
this.allAuthority = allAuthority;
121+
}
122+
123+
public AccessKeysInfoForDescribeAccessKeysOutput createTime(String createTime) {
124+
this.createTime = createTime;
125+
return this;
126+
}
127+
128+
/**
129+
* Get createTime
130+
* @return createTime
131+
**/
132+
@Schema(description = "")
133+
public String getCreateTime() {
134+
return createTime;
135+
}
136+
137+
public void setCreateTime(String createTime) {
138+
this.createTime = createTime;
139+
}
140+
141+
public AccessKeysInfoForDescribeAccessKeysOutput description(String description) {
142+
this.description = description;
143+
return this;
144+
}
145+
146+
/**
147+
* Get description
148+
* @return description
149+
**/
150+
@Schema(description = "")
151+
public String getDescription() {
152+
return description;
153+
}
154+
155+
public void setDescription(String description) {
156+
this.description = description;
157+
}
158+
159+
160+
@Override
161+
public boolean equals(java.lang.Object o) {
162+
if (this == o) {
163+
return true;
164+
}
165+
if (o == null || getClass() != o.getClass()) {
166+
return false;
167+
}
168+
AccessKeysInfoForDescribeAccessKeysOutput accessKeysInfoForDescribeAccessKeysOutput = (AccessKeysInfoForDescribeAccessKeysOutput) o;
169+
return Objects.equals(this.accessKey, accessKeysInfoForDescribeAccessKeysOutput.accessKey) &&
170+
Objects.equals(this.aclConfigJson, accessKeysInfoForDescribeAccessKeysOutput.aclConfigJson) &&
171+
Objects.equals(this.actived, accessKeysInfoForDescribeAccessKeysOutput.actived) &&
172+
Objects.equals(this.allAuthority, accessKeysInfoForDescribeAccessKeysOutput.allAuthority) &&
173+
Objects.equals(this.createTime, accessKeysInfoForDescribeAccessKeysOutput.createTime) &&
174+
Objects.equals(this.description, accessKeysInfoForDescribeAccessKeysOutput.description);
175+
}
176+
177+
@Override
178+
public int hashCode() {
179+
return Objects.hash(accessKey, aclConfigJson, actived, allAuthority, createTime, description);
180+
}
181+
182+
183+
@Override
184+
public String toString() {
185+
StringBuilder sb = new StringBuilder();
186+
sb.append("class AccessKeysInfoForDescribeAccessKeysOutput {\n");
187+
188+
sb.append(" accessKey: ").append(toIndentedString(accessKey)).append("\n");
189+
sb.append(" aclConfigJson: ").append(toIndentedString(aclConfigJson)).append("\n");
190+
sb.append(" actived: ").append(toIndentedString(actived)).append("\n");
191+
sb.append(" allAuthority: ").append(toIndentedString(allAuthority)).append("\n");
192+
sb.append(" createTime: ").append(toIndentedString(createTime)).append("\n");
193+
sb.append(" description: ").append(toIndentedString(description)).append("\n");
194+
sb.append("}");
195+
return sb.toString();
196+
}
197+
198+
/**
199+
* Convert the given object to string with each line indented by 4 spaces
200+
* (except the first line).
201+
*/
202+
private String toIndentedString(java.lang.Object o) {
203+
if (o == null) {
204+
return "null";
205+
}
206+
return o.toString().replace("\n", "\n ");
207+
}
208+
209+
}

‎volcengine-java-sdk-rocketmq/src/main/java/com/volcengine/rocketmq/model/AccessPolicyForCreateTopicInput.java‎

Lines changed: 117 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,117 @@
1+
/*
2+
* rocketmq
3+
* No description provided (generated by Swagger Codegen https://github.com/swagger-api/swagger-codegen)
4+
*
5+
* OpenAPI spec version: common-version
6+
*
7+
*
8+
* NOTE: This class is auto generated by the swagger code generator program.
9+
* https://github.com/swagger-api/swagger-codegen.git
10+
* Do not edit the class manually.
11+
*/
12+
13+
package com.volcengine.rocketmq.model;
14+
15+
import java.util.Objects;
16+
import java.util.Arrays;
17+
import com.google.gson.TypeAdapter;
18+
import com.google.gson.annotations.JsonAdapter;
19+
import com.google.gson.annotations.SerializedName;
20+
import com.google.gson.stream.JsonReader;
21+
import com.google.gson.stream.JsonWriter;
22+
import io.swagger.v3.oas.annotations.media.Schema;
23+
import java.io.IOException;
24+
import javax.validation.constraints.*;
25+
import javax.validation.Valid;
26+
/**
27+
* AccessPolicyForCreateTopicInput
28+
*/
29+
30+
31+
32+
public class AccessPolicyForCreateTopicInput {
33+
@SerializedName("AccessKey")
34+
private String accessKey = null;
35+
36+
@SerializedName("Authority")
37+
private String authority = null;
38+
39+
public AccessPolicyForCreateTopicInput accessKey(String accessKey) {
40+
this.accessKey = accessKey;
41+
return this;
42+
}
43+
44+
/**
45+
* Get accessKey
46+
* @return accessKey
47+
**/
48+
@Size(min=24,max=24) @Schema(description = "")
49+
public String getAccessKey() {
50+
return accessKey;
51+
}
52+
53+
public void setAccessKey(String accessKey) {
54+
this.accessKey = accessKey;
55+
}
56+
57+
public AccessPolicyForCreateTopicInput authority(String authority) {
58+
this.authority = authority;
59+
return this;
60+
}
61+
62+
/**
63+
* Get authority
64+
* @return authority
65+
**/
66+
@Size(min=3,max=4) @Schema(description = "")
67+
public String getAuthority() {
68+
return authority;
69+
}
70+
71+
public void setAuthority(String authority) {
72+
this.authority = authority;
73+
}
74+
75+
76+
@Override
77+
public boolean equals(java.lang.Object o) {
78+
if (this == o) {
79+
return true;
80+
}
81+
if (o == null || getClass() != o.getClass()) {
82+
return false;
83+
}
84+
AccessPolicyForCreateTopicInput accessPolicyForCreateTopicInput = (AccessPolicyForCreateTopicInput) o;
85+
return Objects.equals(this.accessKey, accessPolicyForCreateTopicInput.accessKey) &&
86+
Objects.equals(this.authority, accessPolicyForCreateTopicInput.authority);
87+
}
88+
89+
@Override
90+
public int hashCode() {
91+
return Objects.hash(accessKey, authority);
92+
}
93+
94+
95+
@Override
96+
public String toString() {
97+
StringBuilder sb = new StringBuilder();
98+
sb.append("class AccessPolicyForCreateTopicInput {\n");
99+
100+
sb.append(" accessKey: ").append(toIndentedString(accessKey)).append("\n");
101+
sb.append(" authority: ").append(toIndentedString(authority)).append("\n");
102+
sb.append("}");
103+
return sb.toString();
104+
}
105+
106+
/**
107+
* Convert the given object to string with each line indented by 4 spaces
108+
* (except the first line).
109+
*/
110+
private String toIndentedString(java.lang.Object o) {
111+
if (o == null) {
112+
return "null";
113+
}
114+
return o.toString().replace("\n", "\n ");
115+
}
116+
117+
}

0 commit comments

Comments
 (0)