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 <[email protected]> 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); }
