This is an automated email from the ASF dual-hosted git repository. shenlin pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
commit c4607e5df98f5d8a4eb611404cc6146a5004b1f9 Author: zh378814 <[email protected]> AuthorDate: Tue Sep 5 12:07:40 2023 +0800 fix api destination update --- .../domain/model/apidestination/ApiDestinationService.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination/ApiDestinationService.java b/domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination/ApiDestinationService.java index 0a1c9a0..e723524 100644 --- a/domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination/ApiDestinationService.java +++ b/domain/src/main/java/org/apache/rocketmq/eventbridge/domain/model/apidestination/ApiDestinationService.java @@ -101,7 +101,9 @@ public class ApiDestinationService extends AbstractResourceService { throw new EventBridgeException(EventBridgeErrorCode.ApiDestinationNotExist, apiDestinationDTO.getName()); } ApiDestinationDTO oldApiDestination = getApiDestination(apiDestinationDTO.getAccountId(), apiDestinationDTO.getName()); - if (StringUtils.isBlank(apiDestinationDTO.getConnectionName())) { + if (StringUtils.isNotBlank(apiDestinationDTO.getConnectionName())) { + connectionService.getConnection(apiDestinationDTO.getAccountId(), apiDestinationDTO.getConnectionName()); + } else { apiDestinationDTO.setConnectionName(oldApiDestination.getConnectionName()); } if (apiDestinationDTO.getApiParams() == null) {
