You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by sh...@apache.org on 2022/09/19 02:01:17 UTC
[rocketmq-eventbridge] branch release/1.0.0 updated (3e5c785 -> 8779db0)
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a change to branch release/1.0.0
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
from 3e5c785 [maven-release-plugin] prepare release 1.0.0
new cf153da release: add the apache license and prepare for release.
new dea655c release: add the apache license and prepare for release.
new 8779db0 [maven-release-plugin] prepare release rocketmq-eventbridge-1.0.0
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.gitignore | 2 ++
adapter/api/pom.xml | 4 ++--
adapter/persistence/pom.xml | 4 ++--
.../mybatis/converter/ApiDestinationConverter.java | 13 ++++++-------
.../mybatis/converter/ConnectConverter.java | 22 +++++++++++++---------
adapter/pom.xml | 2 +-
adapter/rpc/pom.xml | 4 ++--
common/pom.xml | 2 +-
.../apache/rocketmq/eventbridge/tools/NetUtil.java | 4 ----
.../rocketmq/eventbridge/tools/TokenUtil.java | 4 ----
.../tools/pattern/FilterPatternTool.java | 2 +-
.../tools/transform/DeleteFieldTransform.java | 3 ---
.../eventbridge/tools/transform/Extract.java | 2 --
.../tools/transform/InsertFieldTransform.java | 17 ++++++++++-------
.../tools/transform/JsonPathExtract.java | 8 ++++----
.../tools/transform/JsonPathTransform.java | 2 +-
.../tools/transform/OriginalTransform.java | 2 +-
.../tools/transform/StringSubstitutorTemplate.java | 3 ---
.../tools/transform/TemplateTransform.java | 3 +--
.../tools/transform/UpdateFieldTransform.java | 17 ++++++++++-------
domain/pom.xml | 6 +-----
.../domain/model/connection/ConnectionService.java | 8 ++++----
pom.xml | 8 +-------
start/pom.xml | 2 +-
24 files changed, 64 insertions(+), 80 deletions(-)
[rocketmq-eventbridge] 03/03: [maven-release-plugin] prepare release rocketmq-eventbridge-1.0.0
Posted by sh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch release/1.0.0
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit 8779db00ecf9243662d8f22d8c40b14f1c5b606a
Author: 2011shenlin <20...@gmail.com>
AuthorDate: Mon Sep 19 10:01:09 2022 +0800
[maven-release-plugin] prepare release rocketmq-eventbridge-1.0.0
---
adapter/api/pom.xml | 4 ++--
adapter/persistence/pom.xml | 4 ++--
adapter/pom.xml | 7 +++----
adapter/rpc/pom.xml | 4 ++--
common/pom.xml | 7 +++----
domain/pom.xml | 7 +++----
pom.xml | 44 ++++++++++++++++++++++----------------------
start/pom.xml | 7 +++----
8 files changed, 40 insertions(+), 44 deletions(-)
diff --git a/adapter/api/pom.xml b/adapter/api/pom.xml
index eecba00..8b7c3b0 100644
--- a/adapter/api/pom.xml
+++ b/adapter/api/pom.xml
@@ -13,12 +13,12 @@
<parent>
<artifactId>rocketmq-eventbridge-adapter</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
<relativePath>../pom.xml</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rocketmq-eventbridge-adapter-api</artifactId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
<properties>
<jakarta.version>2.1.6</jakarta.version>
diff --git a/adapter/persistence/pom.xml b/adapter/persistence/pom.xml
index b83aa2a..2e2a2f1 100644
--- a/adapter/persistence/pom.xml
+++ b/adapter/persistence/pom.xml
@@ -13,12 +13,12 @@
<parent>
<artifactId>rocketmq-eventbridge-adapter</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
<relativePath>../pom.xml</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rocketmq-eventbridge-adapter-persistence</artifactId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
<properties>
<mysql-connector-java.version>8.0.28</mysql-connector-java.version>
diff --git a/adapter/pom.xml b/adapter/pom.xml
index 381f39f..5ca9fc2 100644
--- a/adapter/pom.xml
+++ b/adapter/pom.xml
@@ -9,17 +9,16 @@
OF ANY KIND, either express or implied. See the License for the specific
language governing permissions and limitations under the License. -->
-<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">
+<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">
<parent>
<artifactId>rocketmq-eventbridge</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
<relativePath>../pom.xml</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rocketmq-eventbridge-adapter</artifactId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
<packaging>pom</packaging>
<modules>
diff --git a/adapter/rpc/pom.xml b/adapter/rpc/pom.xml
index 46008ad..1e6b23e 100644
--- a/adapter/rpc/pom.xml
+++ b/adapter/rpc/pom.xml
@@ -13,7 +13,7 @@
<parent>
<artifactId>rocketmq-eventbridge-adapter</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
<relativePath>../pom.xml</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
@@ -25,7 +25,7 @@
<reactor.version>3.1.7.RELEASE</reactor.version>
</properties>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
<dependencies>
<!-- Project Modules -->
<dependency>
diff --git a/common/pom.xml b/common/pom.xml
index bd275ba..07126c5 100644
--- a/common/pom.xml
+++ b/common/pom.xml
@@ -9,17 +9,16 @@
OF ANY KIND, either express or implied. See the License for the specific
language governing permissions and limitations under the License. -->
-<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">
+<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">
<parent>
<artifactId>rocketmq-eventbridge</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rocketmq-eventbridge-common</artifactId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
<properties>
<maven.compiler.source>8</maven.compiler.source>
diff --git a/domain/pom.xml b/domain/pom.xml
index d49bee5..42642d4 100644
--- a/domain/pom.xml
+++ b/domain/pom.xml
@@ -9,17 +9,16 @@
OF ANY KIND, either express or implied. See the License for the specific
language governing permissions and limitations under the License. -->
-<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">
+<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">
<parent>
<artifactId>rocketmq-eventbridge</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rocketmq-eventbridge-domain</artifactId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
<dependencies>
<!-- Project Modules -->
diff --git a/pom.xml b/pom.xml
index 25ba1c7..56fe616 100644
--- a/pom.xml
+++ b/pom.xml
@@ -21,7 +21,7 @@
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-eventbridge</artifactId>
<packaging>pom</packaging>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
<name>Apache RocketMQ EventBridge ${project.version}</name>
<url>https://github.com/apache/rocketmq-eventbridge</url>
@@ -29,7 +29,7 @@
<url>git@github.com:apache/rocketmq-eventbridge.git</url>
<connection>scm:git:git@github.com:apache/rocketmq-eventbridge.git</connection>
<developerConnection>scm:git:git@github.com:apache/rocketmq-eventbridge.git</developerConnection>
- <tag>1.0.0</tag>
+ <tag>rocketmq-eventbridge-1.0.0</tag>
</scm>
<mailingLists>
@@ -322,26 +322,26 @@
</execution>
</executions>
</plugin>
- <plugin>
- <artifactId>maven-checkstyle-plugin</artifactId>
- <version>2.17</version>
- <executions>
- <execution>
- <id>verify</id>
- <phase>verify</phase>
- <configuration>
- <configLocation>style/rmq_checkstyle.xml</configLocation>
- <encoding>UTF-8</encoding>
- <consoleOutput>true</consoleOutput>
- <failsOnError>true</failsOnError>
- <includeTestSourceDirectory>false</includeTestSourceDirectory>
- </configuration>
- <goals>
- <goal>check</goal>
- </goals>
- </execution>
- </executions>
- </plugin>
+<!-- <plugin>-->
+<!-- <artifactId>maven-checkstyle-plugin</artifactId>-->
+<!-- <version>2.17</version>-->
+<!-- <executions>-->
+<!-- <execution>-->
+<!-- <id>verify</id>-->
+<!-- <phase>verify</phase>-->
+<!-- <configuration>-->
+<!-- <configLocation>style/rmq_checkstyle.xml</configLocation>-->
+<!-- <encoding>UTF-8</encoding>-->
+<!-- <consoleOutput>true</consoleOutput>-->
+<!-- <failsOnError>true</failsOnError>-->
+<!-- <includeTestSourceDirectory>false</includeTestSourceDirectory>-->
+<!-- </configuration>-->
+<!-- <goals>-->
+<!-- <goal>check</goal>-->
+<!-- </goals>-->
+<!-- </execution>-->
+<!-- </executions>-->
+<!-- </plugin>-->
<plugin>
<groupId>org.jacoco</groupId>
<artifactId>jacoco-maven-plugin</artifactId>
diff --git a/start/pom.xml b/start/pom.xml
index 4141361..a2eccb9 100644
--- a/start/pom.xml
+++ b/start/pom.xml
@@ -9,17 +9,16 @@
OF ANY KIND, either express or implied. See the License for the specific
language governing permissions and limitations under the License. -->
-<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">
+<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">
<parent>
<artifactId>rocketmq-eventbridge</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rocketmq-eventbridge-start</artifactId>
- <version>1.0.0-SNAPSHOT</version>
+ <version>1.0.0</version>
<properties>
<maven.compiler.source>8</maven.compiler.source>
[rocketmq-eventbridge] 01/03: release: add the apache license and prepare for release.
Posted by sh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch release/1.0.0
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit cf153da8c4dcf94422cd9e97b6dcf77e0f3475d2
Author: 2011shenlin <20...@gmail.com>
AuthorDate: Mon Sep 19 09:57:00 2022 +0800
release: add the apache license and prepare for release.
---
.../org/apache/rocketmq/eventbridge/tools/NetUtil.java | 4 ----
.../apache/rocketmq/eventbridge/tools/TokenUtil.java | 4 ----
.../eventbridge/tools/pattern/FilterPatternTool.java | 2 +-
.../tools/transform/DeleteFieldTransform.java | 3 ---
.../rocketmq/eventbridge/tools/transform/Extract.java | 2 --
.../tools/transform/InsertFieldTransform.java | 17 ++++++++++-------
.../eventbridge/tools/transform/JsonPathExtract.java | 8 ++++----
.../eventbridge/tools/transform/JsonPathTransform.java | 2 +-
.../eventbridge/tools/transform/OriginalTransform.java | 2 +-
.../tools/transform/StringSubstitutorTemplate.java | 3 ---
.../eventbridge/tools/transform/TemplateTransform.java | 3 +--
.../tools/transform/UpdateFieldTransform.java | 17 ++++++++++-------
.../domain/model/connection/ConnectionService.java | 8 ++++----
13 files changed, 32 insertions(+), 43 deletions(-)
diff --git a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/NetUtil.java b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/NetUtil.java
index 41bf466..02a2213 100644
--- a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/NetUtil.java
+++ b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/NetUtil.java
@@ -23,10 +23,6 @@ import java.net.Inet4Address;
import java.net.InetAddress;
import java.net.UnknownHostException;
-/**
- * @Author changfeng
- * @Date 2022/4/25 11:21 上午
- */
public class NetUtil {
public static boolean isIpv4(String ip) {
ip = ip.trim();
diff --git a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/TokenUtil.java b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/TokenUtil.java
index 7a27fdf..72fd683 100644
--- a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/TokenUtil.java
+++ b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/TokenUtil.java
@@ -19,10 +19,6 @@ package org.apache.rocketmq.eventbridge.tools;
import java.util.UUID;
-/**
- * @Author changfeng
- * @Date 2022/5/9 5:15 下午
- */
public class TokenUtil {
/**
* Generate the token of the http source.
diff --git a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/FilterPatternTool.java b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/FilterPatternTool.java
index 46e1d14..a24aa5b 100644
--- a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/FilterPatternTool.java
+++ b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/pattern/FilterPatternTool.java
@@ -24,7 +24,7 @@ import static org.apache.rocketmq.eventbridge.exception.code.FiltterPatternError
public abstract class FilterPatternTool {
- public static void checkFilterPattern(String filterPattern){
+ public static void checkFilterPattern(String filterPattern) {
if (Strings.isNullOrEmpty(filterPattern)) {
throw new EventBridgeException(EventRuleFilterPatternEmpty);
}
diff --git a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/DeleteFieldTransform.java b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/DeleteFieldTransform.java
index cf95456..d1ddd5a 100644
--- a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/DeleteFieldTransform.java
+++ b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/DeleteFieldTransform.java
@@ -18,10 +18,8 @@
package org.apache.rocketmq.eventbridge.tools.transform;
import java.util.ArrayList;
-import java.util.Arrays;
import java.util.List;
import java.util.Map;
-import java.util.stream.Collectors;
import com.google.gson.Gson;
import com.google.gson.JsonElement;
@@ -45,7 +43,6 @@ public class DeleteFieldTransform implements Transform {
Map<String, Object> dataMap = new Gson().fromJson(inputData.toString(), new TypeToken<Map<String, Object>>(){}.getType());
for (String field : fieldList) {
String[] dataList = field.split("\\.");
- System.out.println("dataList is " + Arrays.stream(dataList).collect(Collectors.toList()));
Map<String, Object> tempMap = dataMap;
for (int i = 1; i < dataList.length - 1; i++) {
Object temp = tempMap.get(dataList[i]);
diff --git a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/Extract.java b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/Extract.java
index 69bf29b..7cdc466 100644
--- a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/Extract.java
+++ b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/Extract.java
@@ -20,8 +20,6 @@ package org.apache.rocketmq.eventbridge.tools.transform;
import java.util.List;
import org.apache.rocketmq.eventbridge.exception.EventBridgeException;
-import org.apache.rocketmq.eventbridge.tools.transform.Data;
-import org.apache.rocketmq.eventbridge.tools.transform.Variable;
public interface Extract {
/**
diff --git a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/InsertFieldTransform.java b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/InsertFieldTransform.java
index c8edd30..9c56ecf 100644
--- a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/InsertFieldTransform.java
+++ b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/InsertFieldTransform.java
@@ -35,26 +35,29 @@ public class InsertFieldTransform implements Transform {
public InsertFieldTransform(String extractJsonList) throws EventBridgeException {
JsonElement jsonElement = JsonUtil.parseJsonElement(extractJsonList);
for (JsonElement element : jsonElement.getAsJsonArray()) {
- fieldList.add(new Variable(element.getAsJsonObject().getAsJsonPrimitive(
- TransformFieldEnum.FIELD).getAsString(),
- element.getAsJsonObject().getAsJsonPrimitive(TransformFieldEnum.VALUE)));
+ fieldList.add(new Variable(element.getAsJsonObject()
+ .getAsJsonPrimitive(TransformFieldEnum.FIELD)
+ .getAsString(), element.getAsJsonObject()
+ .getAsJsonPrimitive(TransformFieldEnum.VALUE)));
}
}
@Override
public Data process(Data inputData) throws EventBridgeException {
- Map<String, Object> dataMap = new Gson().fromJson(inputData.toString(), new TypeToken<Map<String, Object>>(){}.getType());
+ Map<String, Object> dataMap = new Gson().fromJson(inputData.toString(),
+ new TypeToken<Map<String, Object>>() {}.getType());
for (Variable v : fieldList) {
- String[] dataList = v.getName().split("\\.");
+ String[] dataList = v.getName()
+ .split("\\.");
Map<String, Object> tempMap = dataMap;
for (int i = 1; i < dataList.length - 1; i++) {
Object temp = tempMap.get(dataList[i]);
if (!(temp instanceof Map)) {
throw new EventBridgeException(TransformErrorCode.InvalidConfig);
}
- tempMap = (Map<String, Object>) temp;
+ tempMap = (Map<String, Object>)temp;
}
- tempMap.put(dataList[dataList.length - 1], ((JsonPrimitive) v.getValue()).getAsString());
+ tempMap.put(dataList[dataList.length - 1], ((JsonPrimitive)v.getValue()).getAsString());
}
String jsonString = JSONObject.toJSONString(dataMap);
return new StringData(jsonString);
diff --git a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathExtract.java b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathExtract.java
index c7b0a86..1138dfe 100644
--- a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathExtract.java
+++ b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathExtract.java
@@ -29,10 +29,10 @@ import org.apache.rocketmq.eventbridge.exception.EventBridgeException;
import static org.apache.rocketmq.eventbridge.tools.transform.Transform.DEFAULT_VALUE_NAME;
/**
- * ALL：[{"name":"SYS_DEFAULT","valueFromJsonPath":"$"}]
- * JSON_PATH：[{"name":"SYS_DEFAULT","valueFromJsonPath":"$.data.template"}]
- * CONSTANT：[{"name":"SYS_DEFAULT","value":"I am a constant value!"}]
- * TEMPLATE：[
+ * ALL:[{"name":"SYS_DEFAULT","valueFromJsonPath":"$"}]
+ * JSON_PATH:[{"name":"SYS_DEFAULT","valueFromJsonPath":"$.data.template"}]
+ * CONSTANT:[{"name":"SYS_DEFAULT","value":"I am a constant value!"}]
+ * TEMPLATE:[
* {"name":"k1","valueFromJsonPath":"$.data.v1"},
* {"name":"k2","valueFromJsonPath":"$.data.v2"}
* ]
diff --git a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathTransform.java b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathTransform.java
index e17aa7a..9b02a78 100644
--- a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathTransform.java
+++ b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/JsonPathTransform.java
@@ -25,7 +25,7 @@ public class JsonPathTransform implements Transform {
/**
* The extact expr
- * e.g："{"id":"$.id","name":"$.data.name"}"
+ * e.g:"{"id":"$.id","name":"$.data.name"}"
*/
private Extract jsonPathExtract;
diff --git a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/OriginalTransform.java b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/OriginalTransform.java
index b644517..ac769e0 100644
--- a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/OriginalTransform.java
+++ b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/OriginalTransform.java
@@ -20,7 +20,7 @@ package org.apache.rocketmq.eventbridge.tools.transform;
public class OriginalTransform implements Transform {
@Override
- public Data process(Data inputData){
+ public Data process(Data inputData) {
return inputData;
}
}
diff --git a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/StringSubstitutorTemplate.java b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/StringSubstitutorTemplate.java
index 3bf371e..3671ba9 100644
--- a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/StringSubstitutorTemplate.java
+++ b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/StringSubstitutorTemplate.java
@@ -64,7 +64,6 @@ public class StringSubstitutorTemplate implements Template {
log.debug("template: " + outputTemplate);
List<Map.Entry<String, JsonElement>> jsonTemplateEntryList = getAndCheckEmbedObject();
- // 如果template中包含EB_SYS_EMBED_OBJECT，则判断Data中该EB_SYS_EMBED_OBJECT对应的数据是否为json，如果是则进行替换并打平
if (jsonTemplateEntryList.size() > 0) {
for (Map.Entry<String, JsonElement> entry : jsonTemplateEntryList) {
String key = removeVariableMark(entry.getValue().getAsJsonObject().get(EB_SYS_EMBED_OBJECT).getAsString());
@@ -93,8 +92,6 @@ public class StringSubstitutorTemplate implements Template {
return jsonTemplateEntryList;
}
JsonElement jsonElement = JsonParser.parseString(outputTemplate);
- // 遍历template，如果有Entry<String, JsonElement>中的JsonElement包含EB_SYS_EMBED_OBJECT，
- // 就将这个entry保存起来，以便后面替换
Deque<Map.Entry<String, JsonElement>> deque = new ArrayDeque<>(jsonElement.getAsJsonObject().entrySet());
while (!deque.isEmpty()) {
Map.Entry<String, JsonElement> elementEntry = deque.pop();
diff --git a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/TemplateTransform.java b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/TemplateTransform.java
index ee125c4..7bb5652 100644
--- a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/TemplateTransform.java
+++ b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/TemplateTransform.java
@@ -25,7 +25,7 @@ public class TemplateTransform implements Transform {
/**
* The extact expr
- * e.g："{"id":"$.id","name":"$.data.name"}"
+ * e.g:"{"id":"$.id","name":"$.data.name"}"
*/
private Extract jsonPathExtract;
@@ -39,7 +39,6 @@ public class TemplateTransform implements Transform {
this.template = template;
}
-
@Override
public Data process(Data inputData) throws EventBridgeException {
List<Variable> variableList = extract(inputData, jsonPathExtract);
diff --git a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/UpdateFieldTransform.java b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/UpdateFieldTransform.java
index ead7742..dc308f3 100644
--- a/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/UpdateFieldTransform.java
+++ b/common/src/main/java/org/apache/rocketmq/eventbridge/tools/transform/UpdateFieldTransform.java
@@ -35,30 +35,33 @@ public class UpdateFieldTransform implements Transform {
public UpdateFieldTransform(String extractJsonList) throws EventBridgeException {
JsonElement jsonElement = JsonUtil.parseJsonElement(extractJsonList);
for (JsonElement element : jsonElement.getAsJsonArray()) {
- fieldList.add(new Variable(element.getAsJsonObject().getAsJsonPrimitive(
- TransformFieldEnum.FIELD).getAsString(),
- element.getAsJsonObject().getAsJsonPrimitive(TransformFieldEnum.VALUE)));
+ fieldList.add(new Variable(element.getAsJsonObject()
+ .getAsJsonPrimitive(TransformFieldEnum.FIELD)
+ .getAsString(), element.getAsJsonObject()
+ .getAsJsonPrimitive(TransformFieldEnum.VALUE)));
}
}
@Override
public Data process(Data inputData) throws EventBridgeException {
- Map<String, Object> dataMap = new Gson().fromJson(inputData.toString(), new TypeToken<Map<String, Object>>(){}.getType());
+ Map<String, Object> dataMap = new Gson().fromJson(inputData.toString(),
+ new TypeToken<Map<String, Object>>() {}.getType());
for (Variable v : fieldList) {
- String[] dataList = v.getName().split("\\.");
+ String[] dataList = v.getName()
+ .split("\\.");
Map<String, Object> tempMap = dataMap;
for (int i = 1; i < dataList.length - 1; i++) {
Object temp = tempMap.get(dataList[i]);
if (!(temp instanceof Map)) {
throw new EventBridgeException(TransformErrorCode.InvalidConfig);
}
- tempMap = (Map<String, Object>) temp;
+ tempMap = (Map<String, Object>)temp;
}
if (tempMap.get(dataList[dataList.length - 1]) == null) {
throw new EventBridgeException(TransformErrorCode.InvalidConfig);
}
- tempMap.put(dataList[dataList.length - 1], ((JsonPrimitive) v.getValue()).getAsString());
+ tempMap.put(dataList[dataList.length - 1], ((JsonPrimitive)v.getValue()).getAsString());
}
String jsonString = JSONObject.toJSONString(dataMap);
return new StringData(jsonString);
diff --git a/domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java b/domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java
index 079260c..e5d5f8b 100644
--- a/domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java
+++ b/domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/connection/ConnectionService.java
@@ -17,8 +17,8 @@
package org.apache.rocketmq.eventbridge.domain.model.connection;
-import com.alibaba.fastjson.JSON;
import com.google.common.collect.Maps;
+import com.google.gson.Gson;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.eventbridge.domain.common.EventBridgeConstants;
import org.apache.rocketmq.eventbridge.domain.common.enums.NetworkTypeEnum;
@@ -171,14 +171,14 @@ public class ConnectionService extends AbstractResourceService {
Map<String, String> basicAuthParametersMap = Maps.newHashMap();
basicAuthParametersMap.put("username", basicAuthParameters.getUsername());
basicAuthParametersMap.put("password", basicAuthParameters.getPassword());
- secretManagerAPI.createSecretName(accountId, connectionName, JSON.toJSONString(basicAuthParametersMap));
+ secretManagerAPI.createSecretName(accountId, connectionName, new Gson().toJson(basicAuthParametersMap));
return authParameters;
}
if (apiKeyAuthParameters != null) {
Map<String, String> apiKeyAuthParametersMap = Maps.newHashMap();
apiKeyAuthParametersMap.put("apiKeyName", apiKeyAuthParameters.getApiKeyName());
apiKeyAuthParametersMap.put("apiKeyValue", apiKeyAuthParameters.getApiKeyValue());
- secretManagerAPI.createSecretName(accountId, connectionName, JSON.toJSONString(apiKeyAuthParametersMap));
+ secretManagerAPI.createSecretName(accountId, connectionName, new Gson().toJson(apiKeyAuthParametersMap));
return authParameters;
}
return authParameters;
@@ -222,7 +222,7 @@ public class ConnectionService extends AbstractResourceService {
Map<String, String> queryStringParameterMap = Maps.newHashMap();
queryStringParameterMap.put("oauthHttpParameterKey", key);
queryStringParameterMap.put("oauthHttpParameterValue", value);
- return secretManagerAPI.createSecretName(accountId, connectionName, JSON.toJSONString(queryStringParameterMap));
+ return secretManagerAPI.createSecretName(accountId, connectionName, new Gson().toJson(queryStringParameterMap));
}
private void checkNetworkType(String type) {
[rocketmq-eventbridge] 02/03: release: add the apache license and prepare for release.
Posted by sh...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a commit to branch release/1.0.0
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit dea655cca1df26bdb33dbfde6f5b0ed7b1268b95
Author: 2011shenlin <20...@gmail.com>
AuthorDate: Mon Sep 19 09:58:18 2022 +0800
release: add the apache license and prepare for release.
---
.gitignore | 2 +
adapter/api/pom.xml | 4 +-
adapter/persistence/pom.xml | 4 +-
.../mybatis/converter/ApiDestinationConverter.java | 13 +++---
.../mybatis/converter/ConnectConverter.java | 22 ++++++----
adapter/pom.xml | 7 +--
adapter/rpc/pom.xml | 4 +-
common/pom.xml | 7 +--
domain/pom.xml | 11 ++---
pom.xml | 50 ++++++++++------------
start/pom.xml | 7 +--
11 files changed, 65 insertions(+), 66 deletions(-)
diff --git a/.gitignore b/.gitignore
index 89cb037..088abd7 100644
--- a/.gitignore
+++ b/.gitignore
@@ -12,6 +12,8 @@ devenv
!LICENSE-BIN
.DS_Store
*.class
+target/
+adapter/target/
adapter/api/target/
adapter/persistence/target/
adapter/rpc/target/
diff --git a/adapter/api/pom.xml b/adapter/api/pom.xml
index b4518e7..eecba00 100644
--- a/adapter/api/pom.xml
+++ b/adapter/api/pom.xml
@@ -13,12 +13,12 @@
<parent>
<artifactId>rocketmq-eventbridge-adapter</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version> 1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rocketmq-eventbridge-adapter-api</artifactId>
- <version> 1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
<properties>
<jakarta.version>2.1.6</jakarta.version>
diff --git a/adapter/persistence/pom.xml b/adapter/persistence/pom.xml
index db1e65f..b83aa2a 100644
--- a/adapter/persistence/pom.xml
+++ b/adapter/persistence/pom.xml
@@ -13,12 +13,12 @@
<parent>
<artifactId>rocketmq-eventbridge-adapter</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version> 1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rocketmq-eventbridge-adapter-persistence</artifactId>
- <version> 1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
<properties>
<mysql-connector-java.version>8.0.28</mysql-connector-java.version>
diff --git a/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/converter/ApiDestinationConverter.java b/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/converter/ApiDestinationConverter.java
index abe2c13..a2a50d5 100644
--- a/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/converter/ApiDestinationConverter.java
+++ b/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/apidestination/mybatis/converter/ApiDestinationConverter.java
@@ -17,16 +17,15 @@
package org.apache.rocketmq.eventbridge.adapter.persistence.apidestination.mybatis.converter;
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
+import java.util.List;
+import java.util.stream.Collectors;
+
+import com.google.gson.Gson;
import org.apache.rocketmq.eventbridge.adapter.persistence.apidestination.mybatis.dataobject.ApiDestinationDO;
import org.apache.rocketmq.eventbridge.domain.model.apidestination.ApiDestinationDTO;
import org.apache.rocketmq.eventbridge.domain.model.apidestination.parameter.HttpApiParameters;
import org.springframework.beans.BeanUtils;
-import java.util.List;
-import java.util.stream.Collectors;
-
public class ApiDestinationConverter {
public static ApiDestinationDO dtoConverterDo(ApiDestinationDTO apiDestinationDTO) {
@@ -35,7 +34,7 @@ public class ApiDestinationConverter {
}
ApiDestinationDO apiDestinationDO = new ApiDestinationDO();
BeanUtils.copyProperties(apiDestinationDTO, apiDestinationDO);
- apiDestinationDO.setApiParams(JSON.toJSONString(apiDestinationDTO.getApiParams()));
+ apiDestinationDO.setApiParams(new Gson().toJson(apiDestinationDTO.getApiParams()));
return apiDestinationDO;
}
@@ -45,7 +44,7 @@ public class ApiDestinationConverter {
}
ApiDestinationDTO apiDestinationDTO = new ApiDestinationDTO();
BeanUtils.copyProperties(apiDestinationDO, apiDestinationDTO);
- apiDestinationDTO.setApiParams(JSONObject.parseObject(apiDestinationDO.getApiParams(), HttpApiParameters.class));
+ apiDestinationDTO.setApiParams(new Gson().fromJson(apiDestinationDO.getApiParams(), HttpApiParameters.class));
return apiDestinationDTO;
}
diff --git a/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/converter/ConnectConverter.java b/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/converter/ConnectConverter.java
index 683422b..5eca675 100644
--- a/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/converter/ConnectConverter.java
+++ b/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/connect/mybatis/converter/ConnectConverter.java
@@ -17,8 +17,7 @@
package org.apache.rocketmq.eventbridge.adapter.persistence.connect.mybatis.converter;
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
import org.apache.rocketmq.eventbridge.adapter.persistence.connect.mybatis.dataobject.ConnectionDO;
import org.apache.rocketmq.eventbridge.domain.model.connection.parameter.AuthParameters;
import org.apache.rocketmq.eventbridge.domain.model.connection.ConnectionDTO;
@@ -36,8 +35,9 @@ public class ConnectConverter {
ConnectionDTO connectionDTO = new ConnectionDTO();
connectionDTO.setConnectionName(connectionDO.getName());
connectionDTO.setDescription(connectionDO.getDescription());
- connectionDTO.setAuthParameters(JSONObject.parseObject(connectionDO.getAuthParameters(), AuthParameters.class));
- connectionDTO.setNetworkParameters(JSONObject.parseObject(connectionDO.getNetworkParameters(), NetworkParameters.class));
+ connectionDTO.setAuthParameters(new Gson().fromJson(connectionDO.getAuthParameters(), AuthParameters.class));
+ connectionDTO.setNetworkParameters(
+ new Gson().fromJson(connectionDO.getNetworkParameters(), NetworkParameters.class));
return connectionDTO;
}
@@ -47,16 +47,20 @@ public class ConnectConverter {
}
ConnectionDO connectionDO = new ConnectionDO();
connectionDO.setAccountId(connectionDTO.getAccountId());
- connectionDO.setAuthorizationType(connectionDTO.getAuthParameters().getAuthorizationType());
+ connectionDO.setAuthorizationType(connectionDTO.getAuthParameters()
+ .getAuthorizationType());
connectionDO.setName(connectionDTO.getConnectionName());
- connectionDO.setNetworkParameters(JSON.toJSONString(connectionDTO.getNetworkParameters()));
+ connectionDO.setNetworkParameters(new Gson().toJson(connectionDTO.getNetworkParameters()));
connectionDO.setDescription(connectionDTO.getDescription());
- connectionDO.setNetworkType(connectionDTO.getNetworkParameters().getNetworkType());
- connectionDO.setAuthParameters(JSONObject.toJSONString(connectionDTO.getAuthParameters()));
+ connectionDO.setNetworkType(connectionDTO.getNetworkParameters()
+ .getNetworkType());
+ connectionDO.setAuthParameters(new Gson().toJson(connectionDTO.getAuthParameters()));
return connectionDO;
}
public static List<ConnectionDTO> doListConvertDtoList(List<ConnectionDO> connectionDOS) {
- return connectionDOS.stream().map(ConnectConverter::doConvertDto).collect(Collectors.toList());
+ return connectionDOS.stream()
+ .map(ConnectConverter::doConvertDto)
+ .collect(Collectors.toList());
}
}
diff --git a/adapter/pom.xml b/adapter/pom.xml
index 1c4bf6e..381f39f 100644
--- a/adapter/pom.xml
+++ b/adapter/pom.xml
@@ -9,16 +9,17 @@
OF ANY KIND, either express or implied. See the License for the specific
language governing permissions and limitations under the License. -->
-<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">
+<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">
<parent>
<artifactId>rocketmq-eventbridge</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rocketmq-eventbridge-adapter</artifactId>
- <version> 1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
<packaging>pom</packaging>
<modules>
diff --git a/adapter/rpc/pom.xml b/adapter/rpc/pom.xml
index 673ed08..46008ad 100644
--- a/adapter/rpc/pom.xml
+++ b/adapter/rpc/pom.xml
@@ -13,7 +13,7 @@
<parent>
<artifactId>rocketmq-eventbridge-adapter</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version> 1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
<relativePath>../pom.xml</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
@@ -25,7 +25,7 @@
<reactor.version>3.1.7.RELEASE</reactor.version>
</properties>
- <version> 1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
<dependencies>
<!-- Project Modules -->
<dependency>
diff --git a/common/pom.xml b/common/pom.xml
index acd9284..bd275ba 100644
--- a/common/pom.xml
+++ b/common/pom.xml
@@ -9,16 +9,17 @@
OF ANY KIND, either express or implied. See the License for the specific
language governing permissions and limitations under the License. -->
-<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">
+<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">
<parent>
<artifactId>rocketmq-eventbridge</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rocketmq-eventbridge-common</artifactId>
- <version> 1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>8</maven.compiler.source>
diff --git a/domain/pom.xml b/domain/pom.xml
index 7bc106d..d49bee5 100644
--- a/domain/pom.xml
+++ b/domain/pom.xml
@@ -9,16 +9,17 @@
OF ANY KIND, either express or implied. See the License for the specific
language governing permissions and limitations under the License. -->
-<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">
+<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">
<parent>
<artifactId>rocketmq-eventbridge</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rocketmq-eventbridge-domain</artifactId>
- <version> 1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
<dependencies>
<!-- Project Modules -->
@@ -68,10 +69,6 @@
<groupId>com.github.ben-manes.caffeine</groupId>
<artifactId>caffeine</artifactId>
</dependency>
- <dependency>
- <groupId>com.alibaba</groupId>
- <artifactId>fastjson</artifactId>
- </dependency>
<!-- Test -->
<dependency>
diff --git a/pom.xml b/pom.xml
index 5979fd8..25ba1c7 100644
--- a/pom.xml
+++ b/pom.xml
@@ -21,7 +21,7 @@
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-eventbridge</artifactId>
<packaging>pom</packaging>
- <version>1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
<name>Apache RocketMQ EventBridge ${project.version}</name>
<url>https://github.com/apache/rocketmq-eventbridge</url>
@@ -29,7 +29,7 @@
<url>git@github.com:apache/rocketmq-eventbridge.git</url>
<connection>scm:git:git@github.com:apache/rocketmq-eventbridge.git</connection>
<developerConnection>scm:git:git@github.com:apache/rocketmq-eventbridge.git</developerConnection>
- <tag> 1.0.0</tag>
+ <tag>1.0.0</tag>
</scm>
<mailingLists>
@@ -89,7 +89,6 @@
<apache.commons-text.version>1.9</apache.commons-text.version>
<mockito.version>2.13.0</mockito.version>
<caffeine.version>2.9.3</caffeine.version>
- <fastjson.version>2.0.2</fastjson.version>
<jacoco-maven-plugin.version>0.8.5</jacoco-maven-plugin.version>
<maven-surefire-plugin.version>2.19.1</maven-surefire-plugin.version>
</properties>
@@ -195,11 +194,6 @@
<artifactId>guava</artifactId>
<version>${guava.version}</version>
</dependency>
- <dependency>
- <groupId>com.alibaba</groupId>
- <artifactId>fastjson</artifactId>
- <version>${fastjson.version}</version>
- </dependency>
<dependency>
<groupId>com.jayway.jsonpath</groupId>
@@ -328,26 +322,26 @@
</execution>
</executions>
</plugin>
-<!-- <plugin>-->
-<!-- <artifactId>maven-checkstyle-plugin</artifactId>-->
-<!-- <version>2.17</version>-->
-<!-- <executions>-->
-<!-- <execution>-->
-<!-- <id>verify</id>-->
-<!-- <phase>verify</phase>-->
-<!-- <configuration>-->
-<!-- <configLocation>style/rmq_checkstyle.xml</configLocation>-->
-<!-- <encoding>UTF-8</encoding>-->
-<!-- <consoleOutput>true</consoleOutput>-->
-<!-- <failsOnError>true</failsOnError>-->
-<!-- <includeTestSourceDirectory>false</includeTestSourceDirectory>-->
-<!-- </configuration>-->
-<!-- <goals>-->
-<!-- <goal>check</goal>-->
-<!-- </goals>-->
-<!-- </execution>-->
-<!-- </executions>-->
-<!-- </plugin>-->
+ <plugin>
+ <artifactId>maven-checkstyle-plugin</artifactId>
+ <version>2.17</version>
+ <executions>
+ <execution>
+ <id>verify</id>
+ <phase>verify</phase>
+ <configuration>
+ <configLocation>style/rmq_checkstyle.xml</configLocation>
+ <encoding>UTF-8</encoding>
+ <consoleOutput>true</consoleOutput>
+ <failsOnError>true</failsOnError>
+ <includeTestSourceDirectory>false</includeTestSourceDirectory>
+ </configuration>
+ <goals>
+ <goal>check</goal>
+ </goals>
+ </execution>
+ </executions>
+ </plugin>
<plugin>
<groupId>org.jacoco</groupId>
<artifactId>jacoco-maven-plugin</artifactId>
diff --git a/start/pom.xml b/start/pom.xml
index 3c60a05..4141361 100644
--- a/start/pom.xml
+++ b/start/pom.xml
@@ -9,16 +9,17 @@
OF ANY KIND, either express or implied. See the License for the specific
language governing permissions and limitations under the License. -->
-<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">
+<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">
<parent>
<artifactId>rocketmq-eventbridge</artifactId>
<groupId>org.apache.rocketmq</groupId>
- <version>1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>rocketmq-eventbridge-start</artifactId>
- <version> 1.0.0</version>
+ <version>1.0.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>8</maven.compiler.source>