diff --git a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/ExtensionsServiceEndpointResource.java b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/ExtensionsServiceEndpointResource.java index 6b65ec8770..13ef985588 100644 --- a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/ExtensionsServiceEndpointResource.java +++ b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/admin/ExtensionsServiceEndpointResource.java @@ -154,8 +154,10 @@ private List getAllAdapterEndpoints( .collect(Collectors.toList()); } - private List getAllDataStreamEndpoints(String username, - List existingItems) { + private List getAllDataStreamEndpoints( + String username, + List existingItems) { + return getAllDataStreams() .stream() .filter(s -> existingItems.stream().noneMatch(item -> s.getAppId().equals(item.getAppId()))) @@ -165,8 +167,10 @@ private List getAllDataStreamEndpoints(String use } - private List getAllDataProcessorEndpoints(String username, - List existingItems) { + private List getAllDataProcessorEndpoints( + String username, + List existingItems) { + return getAllDataProcessors() .stream() .filter(s -> existingItems.stream().noneMatch(item -> s.getAppId().equals(item.getAppId()))) @@ -174,8 +178,10 @@ private List getAllDataProcessorEndpoints(String .collect(Collectors.toList()); } - private List getAllDataSinkEndpoints(String username, - List existingItems) { + private List getAllDataSinkEndpoints( + String username, + List existingItems) { + return getAllDataSinks() .stream() .filter(s -> existingItems.stream().noneMatch(item -> s.getAppId().equals(item.getAppId())))