[incubator-streampipes] 01/05: [hotfix] Extract correct instanceId in health check

[ri...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

riemer pushed a commit to branch experimental-module-federation-494
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git

commit 633b2aa2ee325c9b1a57fbe83fea2fb59450fd5d
Author: Dominik Riemer <do...@gmail.com>
AuthorDate: Fri Feb 4 22:16:24 2022 +0100

    [hotfix] Extract correct instanceId in health check
---
 .../org/apache/streampipes/manager/health/PipelineHealthCheck.java     | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.java b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.java
index 217b73c..ecdd303 100644
--- a/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.java
+++ b/streampipes-pipeline-management/src/main/java/org/apache/streampipes/manager/health/PipelineHealthCheck.java
@@ -18,6 +18,7 @@
 package org.apache.streampipes.manager.health;
 
 
+import org.apache.streampipes.commons.constants.InstanceIdExtractor;
 import org.apache.streampipes.commons.exceptions.NoServiceEndpointsAvailableException;
 import org.apache.streampipes.manager.execution.endpoint.ExtensionsServiceEndpointGenerator;
 import org.apache.streampipes.manager.execution.endpoint.ExtensionsServiceEndpointUtils;
@@ -156,7 +157,7 @@ public class PipelineHealthCheck implements Runnable {
   }
 
   private String extractInstanceId(InvocableStreamPipesEntity graph) {
-    return graph.getElementId().replace(graph.getBelongsTo() + ":", "");
+    return InstanceIdExtractor.extractId(graph.getElementId());
   }