Fix checkstyle

apache · Oct 9, 2023 · dbf4cec · dbf4cec
1 parent d61b2bc
commit dbf4cec
Showing 1 changed file with 12 additions and 6 deletions.
diff --git a/...c/main/java/org/apache/streampipes/rest/impl/admin/ExtensionsServiceEndpointResource.java b/...c/main/java/org/apache/streampipes/rest/impl/admin/ExtensionsServiceEndpointResource.java
@@ -154,8 +154,10 @@ private List<ExtensionsServiceEndpointItem> getAllAdapterEndpoints(
         .collect(Collectors.toList());
   }
 
-  private List<ExtensionsServiceEndpointItem> getAllDataStreamEndpoints(String username,
-                                                                        List<ExtensionsServiceEndpointItem> existingItems) {
+  private List<ExtensionsServiceEndpointItem> getAllDataStreamEndpoints(
+      String username,
+      List<ExtensionsServiceEndpointItem> existingItems) {
+
     return getAllDataStreams()
         .stream()
         .filter(s -> existingItems.stream().noneMatch(item -> s.getAppId().equals(item.getAppId())))
@@ -165,17 +167,21 @@ private List<ExtensionsServiceEndpointItem> getAllDataStreamEndpoints(String use
   }
 
 
-  private List<ExtensionsServiceEndpointItem> getAllDataProcessorEndpoints(String username,
-                                                                           List<ExtensionsServiceEndpointItem> existingItems) {
+  private List<ExtensionsServiceEndpointItem> getAllDataProcessorEndpoints(
+      String username,
+      List<ExtensionsServiceEndpointItem> existingItems) {
+
     return getAllDataProcessors()
         .stream()
         .filter(s -> existingItems.stream().noneMatch(item -> s.getAppId().equals(item.getAppId())))
         .map(source -> makeItem(source, "sepa"))
         .collect(Collectors.toList());
   }
 
-  private List<ExtensionsServiceEndpointItem> getAllDataSinkEndpoints(String username,
-                                                                      List<ExtensionsServiceEndpointItem> existingItems) {
+  private List<ExtensionsServiceEndpointItem> getAllDataSinkEndpoints(
+      String username,
+      List<ExtensionsServiceEndpointItem> existingItems) {
+
     return getAllDataSinks()
         .stream()
         .filter(s -> existingItems.stream().noneMatch(item -> s.getAppId().equals(item.getAppId())))