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:42 UTC
[rocketmq-eventbridge] 02/02: All overriding methods must be annotated with @Override
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);
}