This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch CAMEL-20798-gcp in repository https://gitbox.apache.org/repos/asf/camel.git
commit 4c391d138d59e062ca9d65c5f4a7dae3a243ff64 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Fri Jun 28 11:06:36 2024 +0200 CAMEL-20798: EndpointServiceLocation on components to make it possible to know which remote system Camel connects to to assist for monitoring and observability - Google Secrets Manager Signed-off-by: Andrea Cosentino <anco...@gmail.com> --- .../secret/manager/GoogleSecretManagerEndpoint.java | 19 ++++++++++++++++++- 1 file changed, 18 insertions(+), 1 deletion(-) diff --git a/components/camel-google/camel-google-secret-manager/src/main/java/org/apache/camel/component/google/secret/manager/GoogleSecretManagerEndpoint.java b/components/camel-google/camel-google-secret-manager/src/main/java/org/apache/camel/component/google/secret/manager/GoogleSecretManagerEndpoint.java index d9b5f5e25af..39b19f96883 100644 --- a/components/camel-google/camel-google-secret-manager/src/main/java/org/apache/camel/component/google/secret/manager/GoogleSecretManagerEndpoint.java +++ b/components/camel-google/camel-google-secret-manager/src/main/java/org/apache/camel/component/google/secret/manager/GoogleSecretManagerEndpoint.java @@ -21,10 +21,14 @@ import org.apache.camel.Category; import org.apache.camel.Consumer; import org.apache.camel.Processor; import org.apache.camel.Producer; +import org.apache.camel.spi.EndpointServiceLocation; import org.apache.camel.spi.Metadata; import org.apache.camel.spi.UriEndpoint; import org.apache.camel.spi.UriParam; import org.apache.camel.support.DefaultEndpoint; +import org.apache.camel.util.ObjectHelper; + +import java.util.Map; /** * Manage Google Secret Manager Secrets @@ -38,7 +42,7 @@ import org.apache.camel.support.DefaultEndpoint; @Metadata(annotations = { "vault=google-secret-manager", }) -public class GoogleSecretManagerEndpoint extends DefaultEndpoint { +public class GoogleSecretManagerEndpoint extends DefaultEndpoint implements EndpointServiceLocation { @UriParam private GoogleSecretManagerConfiguration configuration; @@ -93,4 +97,17 @@ public class GoogleSecretManagerEndpoint extends DefaultEndpoint { return secretManagerServiceClient; } + @Override + public String getServiceUrl() { + if (ObjectHelper.isNotEmpty(ObjectHelper.isNotEmpty(configuration.getProject()) && ObjectHelper.isNotEmpty(configuration.getClient()))) { + return getServiceProtocol() + ":" + configuration.getProject() + ":" + configuration.getClient(); + } + return null; + } + + @Override + public String getServiceProtocol() { + return "secrets-manager"; + } + }