You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by yu...@apache.org on 2022/04/18 06:04:40 UTC
[rocketmq-eventbridge] branch main updated (3d1f809 -> ba3aa9a)
This is an automated email from the ASF dual-hosted git repository.
yukon pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
from 3d1f809 Bump logback-core from 1.2.3 to 1.2.9
new cd3499a Redundant declaration: @SpringBootApplication already applies given @ComponentScan
new ba3aa9a All overriding methods must be annotated with @Override
The 2 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:
.../persistence/rule/mybatis/repository/MybatisEventRuleRepository.java | 1 +
.../eventbridge/adapter/rpc/impl/connect/dto/DeleteConnectorRequest.java | 1 +
.../adapter/rpc/impl/connect/dto/GetConnectorStatusRequest.java | 1 +
.../eventbridge/adapter/rpc/impl/connect/dto/StartConnectorRequest.java | 1 +
.../eventbridge/adapter/rpc/impl/connect/dto/StopConnectorRequest.java | 1 +
start/src/main/java/org/apache/rocketmq/eventbridge/Main.java | 1 -
6 files changed, 5 insertions(+), 1 deletion(-)
[rocketmq-eventbridge] 01/02: Redundant declaration: @SpringBootApplication already applies given @ComponentScan
Posted by yu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
yukon pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit cd3499a06690daa9945bc1306981a7928fe20ea0
Author: zhaohai <zh...@126.com>
AuthorDate: Thu Apr 14 20:01:12 2022 +0800
Redundant declaration: @SpringBootApplication already applies given @ComponentScan
---
start/src/main/java/org/apache/rocketmq/eventbridge/Main.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/start/src/main/java/org/apache/rocketmq/eventbridge/Main.java b/start/src/main/java/org/apache/rocketmq/eventbridge/Main.java
index 5976490..84a8396 100644
--- a/start/src/main/java/org/apache/rocketmq/eventbridge/Main.java
+++ b/start/src/main/java/org/apache/rocketmq/eventbridge/Main.java
@@ -22,7 +22,6 @@ import org.springframework.cache.annotation.EnableCaching;
import org.springframework.context.annotation.ComponentScan;
@SpringBootApplication
-@ComponentScan
@EnableCaching
public class Main {
public static void main(String[] args) {
[rocketmq-eventbridge] 02/02: All overriding methods must be annotated with @Override
Posted by yu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
yukon pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit ba3aa9af6b614aafb6e224c1454ff5988103f45c
Author: zhaohai <zh...@126.com>
AuthorDate: Thu Apr 14 20:04:17 2022 +0800
All overriding methods must be annotated with @Override
---
.../persistence/rule/mybatis/repository/MybatisEventRuleRepository.java | 1 +
.../eventbridge/adapter/rpc/impl/connect/dto/DeleteConnectorRequest.java | 1 +
.../adapter/rpc/impl/connect/dto/GetConnectorStatusRequest.java | 1 +
.../eventbridge/adapter/rpc/impl/connect/dto/StartConnectorRequest.java | 1 +
.../eventbridge/adapter/rpc/impl/connect/dto/StopConnectorRequest.java | 1 +
5 files changed, 5 insertions(+)
diff --git a/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/rule/mybatis/repository/MybatisEventRuleRepository.java b/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/rule/mybatis/repository/MybatisEventRuleRepository.java
index 73fb58c..726e2ed 100644
--- a/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/rule/mybatis/repository/MybatisEventRuleRepository.java
+++ b/adapter/persistence/src/main/java/org/apache/rocketmq/eventbridge/adapter/persistence/rule/mybatis/repository/MybatisEventRuleRepository.java
@@ -59,6 +59,7 @@
return eventRuleMapper.deleteEventRule(accountId, eventBusName, eventRuleName) == 1;
}
+ @Override
public EventRule getEventRule(String accountId, String eventBusName, String eventRuleName) {
return eventRuleMapper.getEventRule(accountId, eventBusName, eventRuleName);
diff --git a/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/DeleteConnectorRequest.java b/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/DeleteConnectorRequest.java
index d0c5365..6490fb3 100644
--- a/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/DeleteConnectorRequest.java
+++ b/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/DeleteConnectorRequest.java
@@ -32,6 +32,7 @@ public class DeleteConnectorRequest extends BaseConnectorRequest {
super(endpoint);
}
+ @Override
public String toString() {
return String.format(endpoint + path, name);
}
diff --git a/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/GetConnectorStatusRequest.java b/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/GetConnectorStatusRequest.java
index 9a590e5..3273e5d 100644
--- a/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/GetConnectorStatusRequest.java
+++ b/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/GetConnectorStatusRequest.java
@@ -32,6 +32,7 @@ public class GetConnectorStatusRequest extends BaseConnectorRequest {
super(endpoint);
}
+ @Override
public String toString() {
return String.format(endpoint + path, name);
}
diff --git a/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/StartConnectorRequest.java b/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/StartConnectorRequest.java
index e73a279..5c3546c 100644
--- a/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/StartConnectorRequest.java
+++ b/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/StartConnectorRequest.java
@@ -32,6 +32,7 @@ public class StartConnectorRequest extends BaseConnectorRequest {
super(endpoint);
}
+ @Override
public String toString() {
return String.format(endpoint + path, name);
}
diff --git a/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/StopConnectorRequest.java b/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/StopConnectorRequest.java
index ad99450..b196669 100644
--- a/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/StopConnectorRequest.java
+++ b/adapter/rpc/src/main/java/org/apache/rocketmq/eventbridge/adapter/rpc/impl/connect/dto/StopConnectorRequest.java
@@ -32,6 +32,7 @@ public class StopConnectorRequest extends BaseConnectorRequest {
super(endpoint);
}
+ @Override
public String toString() {
return String.format(endpoint + path, name);
}