This is an automated email from the ASF dual-hosted git repository.
riemer pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes.git
The following commit(s) were added to refs/heads/dev by this push:
new 06a36d6 [STREAMPIPES-272] Add abstract resource class for
authenticated API requests
06a36d6 is described below
commit 06a36d6528c853d96bae93dbfccac4b78334bc91
Author: Dominik Riemer <[email protected]>
AuthorDate: Thu Feb 11 22:31:57 2021 +0100
[STREAMPIPES-272] Add abstract resource class for authenticated API requests
---
.../backend/StreamPipesResourceConfig.java | 2 +-
.../apache/streampipes/ps/DataLakeResourceV3.java | 4 ++--
.../ps/PipelineElementTemplateResource.java | 4 ++--
.../rest/impl/AbstractAuthGuardedRestResource.java | 22 +++++++++++++++++++++-
.../rest/impl/AbstractRestResource.java | 2 +-
.../streampipes/rest/impl/AssetDashboard.java | 2 +-
.../streampipes/rest/impl/Authentication.java | 2 +-
.../apache/streampipes/rest/impl/AutoComplete.java | 4 ++--
.../streampipes/rest/impl/CategoryResource.java | 2 +-
.../apache/streampipes/rest/impl/ConsulConfig.java | 2 +-
.../rest/impl/ContainerProvidedOptions.java | 2 +-
.../org/apache/streampipes/rest/impl/Couchdb.java | 2 +-
.../apache/streampipes/rest/impl/DataStream.java | 2 +-
.../apache/streampipes/rest/impl/Deployment.java | 2 +-
.../rest/impl/InternalPipelineTemplates.java | 2 +-
.../streampipes/rest/impl/LabelResource.java | 2 +-
.../rest/impl/MeasurementUnitResource.java | 2 +-
.../apache/streampipes/rest/impl/Notification.java | 2 +-
.../streampipes/rest/impl/OntologyContext.java | 2 +-
.../streampipes/rest/impl/OntologyKnowledge.java | 2 +-
.../rest/impl/OntologyMeasurementUnit.java | 2 +-
.../rest/impl/OntologyPipelineElement.java | 2 +-
.../streampipes/rest/impl/PipelineCache.java | 2 +-
.../streampipes/rest/impl/PipelineCategory.java | 2 +-
.../rest/impl/PipelineElementAsset.java | 2 +-
.../rest/impl/PipelineElementCategory.java | 2 +-
.../streampipes/rest/impl/PipelineElementFile.java | 2 +-
.../rest/impl/PipelineElementImport.java | 2 +-
.../rest/impl/PipelineElementRuntimeInfo.java | 2 +-
.../streampipes/rest/impl/PipelineMonitoring.java | 2 +-
...WithUserResource.java => PipelineResource.java} | 4 ++--
.../streampipes/rest/impl/PipelineTemplate.java | 2 +-
.../apache/streampipes/rest/impl/RdfEndpoint.java | 2 +-
.../rest/impl/SemanticEventConsumer.java | 2 +-
.../rest/impl/SemanticEventProcessingAgent.java | 2 +-
.../rest/impl/SemanticEventProducer.java | 2 +-
.../org/apache/streampipes/rest/impl/Setup.java | 2 +-
.../org/apache/streampipes/rest/impl/User.java | 2 +-
.../org/apache/streampipes/rest/impl/Version.java | 2 +-
.../streampipes/rest/impl/VirtualSensor.java | 2 +-
.../streampipes/rest/impl/Visualization.java | 2 +-
.../impl/dashboard/AbstractDashboardResource.java | 4 ++--
.../rest/impl/dashboard/DashboardWidget.java | 4 ++--
.../rest/impl/dashboard/VisualizablePipeline.java | 4 ++--
.../impl/datalake/DataLakeNoUserResourceV3.java | 4 ++--
.../rest/impl/datalake/DataLakeWidgetResource.java | 4 ++--
.../rest/impl/nouser/FileServingResource.java | 4 ++--
.../impl/nouser/PipelineElementImportNoUser.java | 4 ++--
.../rest/impl/nouser/PipelineNoUserResource.java | 4 ++--
.../rest/management/PipelineManagement.java | 4 ++--
50 files changed, 83 insertions(+), 63 deletions(-)
diff --git
a/streampipes-backend/src/main/java/org/apache/streampipes/backend/StreamPipesResourceConfig.java
b/streampipes-backend/src/main/java/org/apache/streampipes/backend/StreamPipesResourceConfig.java
index c880bb8..2261149 100644
---
a/streampipes-backend/src/main/java/org/apache/streampipes/backend/StreamPipesResourceConfig.java
+++
b/streampipes-backend/src/main/java/org/apache/streampipes/backend/StreamPipesResourceConfig.java
@@ -81,7 +81,7 @@ public class StreamPipesResourceConfig extends ResourceConfig
{
register(PipelineMonitoring.class);
register(PipelineNoUserResource.class);
register(PipelineTemplate.class);
- register(PipelineWithUserResource.class);
+ register(PipelineResource.class);
register(RdfEndpoint.class);
register(SemanticEventConsumer.class);
register(SemanticEventProcessingAgent.class);
diff --git
a/streampipes-platform-services/src/main/java/org/apache/streampipes/ps/DataLakeResourceV3.java
b/streampipes-platform-services/src/main/java/org/apache/streampipes/ps/DataLakeResourceV3.java
index cfc9b2f..d8d814c 100644
---
a/streampipes-platform-services/src/main/java/org/apache/streampipes/ps/DataLakeResourceV3.java
+++
b/streampipes-platform-services/src/main/java/org/apache/streampipes/ps/DataLakeResourceV3.java
@@ -25,7 +25,7 @@ import org.apache.streampipes.model.datalake.DataResult;
import org.apache.streampipes.model.datalake.GroupedDataResult;
import org.apache.streampipes.model.datalake.PageResult;
import org.apache.streampipes.model.message.Notification;
-import org.apache.streampipes.rest.impl.AbstractRestInterface;
+import org.apache.streampipes.rest.impl.AbstractRestResource;
import org.apache.streampipes.rest.shared.annotation.GsonWithIds;
import org.apache.streampipes.rest.shared.annotation.JacksonSerialized;
@@ -35,7 +35,7 @@ import java.io.IOException;
import java.util.List;
@Path("/v3/users/{username}/datalake")
-public class DataLakeResourceV3 extends AbstractRestInterface {
+public class DataLakeResourceV3 extends AbstractRestResource {
private DataLakeManagementV3 dataLakeManagement;
public DataLakeResourceV3() {
diff --git
a/streampipes-platform-services/src/main/java/org/apache/streampipes/ps/PipelineElementTemplateResource.java
b/streampipes-platform-services/src/main/java/org/apache/streampipes/ps/PipelineElementTemplateResource.java
index 7509320..d405b5b 100644
---
a/streampipes-platform-services/src/main/java/org/apache/streampipes/ps/PipelineElementTemplateResource.java
+++
b/streampipes-platform-services/src/main/java/org/apache/streampipes/ps/PipelineElementTemplateResource.java
@@ -29,7 +29,7 @@ import
org.apache.streampipes.manager.template.DataSinkTemplateHandler;
import org.apache.streampipes.model.graph.DataProcessorInvocation;
import org.apache.streampipes.model.graph.DataSinkInvocation;
import org.apache.streampipes.model.template.PipelineElementTemplate;
-import org.apache.streampipes.rest.impl.AbstractRestInterface;
+import org.apache.streampipes.rest.impl.AbstractRestResource;
import org.apache.streampipes.rest.shared.annotation.JacksonSerialized;
import javax.ws.rs.*;
@@ -37,7 +37,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/users/{username}/pipeline-element-templates")
-public class PipelineElementTemplateResource extends AbstractRestInterface {
+public class PipelineElementTemplateResource extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AbstractAuthGuardedRestResource.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AbstractAuthGuardedRestResource.java
index c2a4de8..c1d73c0 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AbstractAuthGuardedRestResource.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AbstractAuthGuardedRestResource.java
@@ -17,5 +17,25 @@
*/
package org.apache.streampipes.rest.impl;
-public class AuthenticatedAbstractRestInterface extends AbstractRestInterface {
+import org.apache.streampipes.model.client.user.User;
+
+import javax.ws.rs.core.Context;
+import javax.ws.rs.core.SecurityContext;
+
+public class AbstractAuthGuardedRestResource extends AbstractRestResource {
+
+ @Context
+ protected SecurityContext securityContext;
+
+ protected boolean isAuthenticated() {
+ return this.securityContext.getUserPrincipal() != null;
+ }
+
+ protected String getAuthenticatedUsername() {
+ return this.securityContext.getUserPrincipal().getName();
+ }
+
+ protected User getAuthenticatedUser() {
+ return getUserStorage().getUser(getAuthenticatedUsername());
+ }
}
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AbstractRestResource.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AbstractRestResource.java
index 1ea5f92..a40ed88 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AbstractRestResource.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AbstractRestResource.java
@@ -45,7 +45,7 @@ import java.net.URISyntaxException;
import java.net.URLDecoder;
import java.util.List;
-public abstract class AbstractRestInterface extends
AbstractSharedRestInterface {
+public abstract class AbstractRestResource extends AbstractSharedRestInterface
{
protected <T> String toJsonLd(T object) {
try {
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AssetDashboard.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AssetDashboard.java
index 3d35906..5cdabe0 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AssetDashboard.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AssetDashboard.java
@@ -34,7 +34,7 @@ import java.nio.file.Files;
import java.nio.file.Paths;
@Path("/v2/users/{username}/asset-dashboards")
-public class AssetDashboard extends AbstractRestInterface {
+public class AssetDashboard extends AbstractRestResource {
private static final String APP_ID =
"org.apache.streampipes.apps.assetdashboard";
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Authentication.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Authentication.java
index 9e07d78..5af79b7 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Authentication.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Authentication.java
@@ -40,7 +40,7 @@ import java.util.HashSet;
import java.util.Set;
@Path("/v2/admin")
-public class Authentication extends AbstractRestInterface {
+public class Authentication extends AbstractRestResource {
@Produces(MediaType.APPLICATION_JSON)
@Consumes(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AutoComplete.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AutoComplete.java
index b927909..c9254e4 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AutoComplete.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/AutoComplete.java
@@ -40,7 +40,7 @@ import
org.apache.streampipes.storage.rdf4j.ontology.QueryExecutor;
import org.apache.streampipes.storage.rdf4j.sparql.QueryBuilder;
@Path("/v2/autocomplete")
-public class AutoComplete extends AbstractRestInterface {
+public class AutoComplete extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
@@ -72,4 +72,4 @@ public class AutoComplete extends AbstractRestInterface {
.getBackgroundKnowledgeStorage().getOntologyResult(ontologyQuery));
}
-}
\ No newline at end of file
+}
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/CategoryResource.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/CategoryResource.java
index dd93576..9ea8ac6 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/CategoryResource.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/CategoryResource.java
@@ -30,7 +30,7 @@ import java.util.HashMap;
import java.util.Map;
@Path("/v2/users/{username}/labeling/category")
-public class CategoryResource extends AbstractRestInterface {
+public class CategoryResource extends AbstractRestResource {
@GET
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/ConsulConfig.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/ConsulConfig.java
index 841ae55..f0327fb 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/ConsulConfig.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/ConsulConfig.java
@@ -41,7 +41,7 @@ import java.util.Map;
import static org.apache.streampipes.container.util.ConsulUtil.updateConfig;
@Path("/v2/consul")
-public class ConsulConfig extends AbstractRestInterface {
+public class ConsulConfig extends AbstractRestResource {
private static Logger LOG = LoggerFactory.getLogger(ConsulConfig.class);
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/ContainerProvidedOptions.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/ContainerProvidedOptions.java
index ed929be..4eca9d4 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/ContainerProvidedOptions.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/ContainerProvidedOptions.java
@@ -29,7 +29,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/users/{username}/pe/options")
-public class ContainerProvidedOptions extends AbstractRestInterface {
+public class ContainerProvidedOptions extends AbstractRestResource {
@POST
@Consumes(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Couchdb.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Couchdb.java
index 635115c..524b650 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Couchdb.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Couchdb.java
@@ -33,7 +33,7 @@ import javax.ws.rs.core.Response;
import java.util.List;
@Path("/v2/couchdb/{table}")
-public class Couchdb extends AbstractRestInterface {
+public class Couchdb extends AbstractRestResource {
@GET
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/DataStream.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/DataStream.java
index d39418a..db9f7fc 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/DataStream.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/DataStream.java
@@ -28,7 +28,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/users/{username}/streams")
-public class DataStream extends AbstractRestInterface {
+public class DataStream extends AbstractRestResource {
@Path("/update")
@POST
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Deployment.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Deployment.java
index 952faf8..bdc15c1 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Deployment.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Deployment.java
@@ -45,7 +45,7 @@ import java.lang.reflect.InvocationTargetException;
@Path("/v2/users/{username}/deploy")
-public class Deployment extends AbstractRestInterface {
+public class Deployment extends AbstractRestResource {
@POST
@Path("/implementation")
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/InternalPipelineTemplates.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/InternalPipelineTemplates.java
index d4d19d4..fdbaa94 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/InternalPipelineTemplates.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/InternalPipelineTemplates.java
@@ -42,7 +42,7 @@ import java.util.List;
import java.util.Map;
@Path("/v2/users/{username}/internal-pipelines")
-public class InternalPipelineTemplates extends AbstractRestInterface {
+public class InternalPipelineTemplates extends AbstractRestResource {
private static final Logger LOG =
LoggerFactory.getLogger(InternalPipelineTemplates.class);
private Map<String, Template> templates;
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/LabelResource.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/LabelResource.java
index 83ec7ae..d0b5a40 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/LabelResource.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/LabelResource.java
@@ -30,7 +30,7 @@ import java.util.HashMap;
import java.util.Map;
@Path("/v2/users/{username}/labeling/label")
-public class LabelResource extends AbstractRestInterface {
+public class LabelResource extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/MeasurementUnitResource.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/MeasurementUnitResource.java
index 2909b5b..630fbf7 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/MeasurementUnitResource.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/MeasurementUnitResource.java
@@ -28,7 +28,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/users/{username}/measurement-units")
-public class MeasurementUnitResource extends AbstractRestInterface {
+public class MeasurementUnitResource extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Notification.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Notification.java
index 4247087..6a03bfd 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Notification.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Notification.java
@@ -26,7 +26,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/users/{username}/notifications")
-public class Notification extends AbstractRestInterface {
+public class Notification extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyContext.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyContext.java
index 3ebcbd0..7557bcd 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyContext.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyContext.java
@@ -29,7 +29,7 @@ import javax.ws.rs.core.Response;
import java.io.InputStream;
@Path("/v2/contexts")
-public class OntologyContext extends AbstractRestInterface {
+public class OntologyContext extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyKnowledge.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyKnowledge.java
index b7d523d..8e05645 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyKnowledge.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyKnowledge.java
@@ -30,7 +30,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/ontology")
-public class OntologyKnowledge extends AbstractRestInterface {
+public class OntologyKnowledge extends AbstractRestResource {
@Path("/types")
@GET
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyMeasurementUnit.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyMeasurementUnit.java
index b6a415b..0bcbd81 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyMeasurementUnit.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyMeasurementUnit.java
@@ -28,7 +28,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/units")
-public class OntologyMeasurementUnit extends AbstractRestInterface {
+public class OntologyMeasurementUnit extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyPipelineElement.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyPipelineElement.java
index 2f102f7..ea9bf2d 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyPipelineElement.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/OntologyPipelineElement.java
@@ -34,7 +34,7 @@ import java.util.ArrayList;
import java.util.List;
@Path("/v2/ontology")
-public class OntologyPipelineElement extends AbstractRestInterface{
+public class OntologyPipelineElement extends AbstractRestResource {
@Path("/sources")
@GET
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineCache.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineCache.java
index 2711fa2..c699a02 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineCache.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineCache.java
@@ -23,7 +23,7 @@ import javax.ws.rs.core.Response;
import java.util.concurrent.ConcurrentHashMap;
@Path("/v2/users/{username}/pipeline-cache")
-public class PipelineCache extends AbstractRestInterface {
+public class PipelineCache extends AbstractRestResource {
private static ConcurrentHashMap<String, String> cachedPipelines = new
ConcurrentHashMap<>();
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineCategory.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineCategory.java
index 5ac049e..c55fcf0 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineCategory.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineCategory.java
@@ -27,7 +27,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/users/{username}/pipelinecategories")
-public class PipelineCategory extends AbstractRestInterface {
+public class PipelineCategory extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementAsset.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementAsset.java
index 30e2723..dff9b4a 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementAsset.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementAsset.java
@@ -30,7 +30,7 @@ import javax.ws.rs.core.Response;
import java.io.IOException;
@Path("/v2/pe")
-public class PipelineElementAsset extends AbstractRestInterface {
+public class PipelineElementAsset extends AbstractRestResource {
private static final Logger LOG =
LoggerFactory.getLogger(PipelineElementAsset.class);
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementCategory.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementCategory.java
index a551cce..c83e341 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementCategory.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementCategory.java
@@ -35,7 +35,7 @@ import java.util.List;
import java.util.stream.Collectors;
@Path("/v2/categories")
-public class PipelineElementCategory extends AbstractRestInterface {
+public class PipelineElementCategory extends AbstractRestResource {
@GET
@Path("/ep")
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementFile.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementFile.java
index 49e2f6e..bd36e42 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementFile.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementFile.java
@@ -31,7 +31,7 @@ import java.util.List;
import java.util.stream.Collectors;
@Path("/v2/users/{username}/files")
-public class PipelineElementFile extends AbstractRestInterface {
+public class PipelineElementFile extends AbstractRestResource {
@POST
@Consumes(MediaType.MULTIPART_FORM_DATA)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementImport.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementImport.java
index c8a580e..290a795 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementImport.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementImport.java
@@ -44,7 +44,7 @@ import java.util.ArrayList;
import java.util.List;
@Path("/v2/users/{username}/element")
-public class PipelineElementImport extends AbstractRestInterface {
+public class PipelineElementImport extends AbstractRestResource {
private static final Logger LOG =
LoggerFactory.getLogger(PipelineElementImport.class);
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementRuntimeInfo.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementRuntimeInfo.java
index fb126be..76f7e81 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementRuntimeInfo.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineElementRuntimeInfo.java
@@ -31,7 +31,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/users/{username}/pipeline-element/runtime")
-public class PipelineElementRuntimeInfo extends AbstractRestInterface {
+public class PipelineElementRuntimeInfo extends AbstractRestResource {
@POST
@JacksonSerialized
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineMonitoring.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineMonitoring.java
index 83f8db6..e25f35e 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineMonitoring.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineMonitoring.java
@@ -29,7 +29,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/users/{username}/pipeline-monitoring")
-public class PipelineMonitoring extends AbstractRestInterface implements
IPipelineMonitoring {
+public class PipelineMonitoring extends AbstractRestResource implements
IPipelineMonitoring {
@JacksonSerialized
@Path("{pipelineId}")
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineWithUserResource.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineResource.java
similarity index 99%
rename from
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineWithUserResource.java
rename to
streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineResource.java
index 4bc159d..6c58371 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineWithUserResource.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineResource.java
@@ -48,9 +48,9 @@ import java.util.Date;
import java.util.UUID;
@Path("/v2/users/{username}/pipelines")
-public class PipelineWithUserResource extends AbstractRestInterface {
+public class PipelineResource extends AbstractAuthGuardedRestResource {
- private static final Logger logger =
LoggerFactory.getLogger(PipelineWithUserResource.class);
+ private static final Logger logger =
LoggerFactory.getLogger(PipelineResource.class);
public Response getAvailable(String username) {
// TODO Auto-generated method stub
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineTemplate.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineTemplate.java
index da687a1..3c134e6 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineTemplate.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/PipelineTemplate.java
@@ -37,7 +37,7 @@ import java.util.ArrayList;
import java.util.List;
@Path("/v2/users/{username}/pipeline-templates")
-public class PipelineTemplate extends AbstractRestInterface {
+public class PipelineTemplate extends AbstractRestResource {
@GET
@Path("/streams")
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/RdfEndpoint.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/RdfEndpoint.java
index b1bda30..3b8c37c 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/RdfEndpoint.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/RdfEndpoint.java
@@ -34,7 +34,7 @@ import java.util.List;
import java.util.stream.Collectors;
@Path("/v2/users/{username}/rdfendpoints")
-public class RdfEndpoint extends AbstractRestInterface {
+public class RdfEndpoint extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/SemanticEventConsumer.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/SemanticEventConsumer.java
index 7364e19..41aa77a 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/SemanticEventConsumer.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/SemanticEventConsumer.java
@@ -37,7 +37,7 @@ import java.util.List;
import java.util.stream.Collectors;
@Path("/v2/users/{username}/actions")
-public class SemanticEventConsumer extends AbstractRestInterface implements
IPipelineElement {
+public class SemanticEventConsumer extends AbstractRestResource implements
IPipelineElement {
@GET
@Path("/available")
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/SemanticEventProcessingAgent.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/SemanticEventProcessingAgent.java
index 109bfdb..fcbe241 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/SemanticEventProcessingAgent.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/SemanticEventProcessingAgent.java
@@ -36,7 +36,7 @@ import java.util.List;
import java.util.stream.Collectors;
@Path("/v2/users/{username}/sepas")
-public class SemanticEventProcessingAgent extends AbstractRestInterface
implements IPipelineElement {
+public class SemanticEventProcessingAgent extends AbstractRestResource
implements IPipelineElement {
@GET
@Path("/available")
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/SemanticEventProducer.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/SemanticEventProducer.java
index 36021ce..1bbd8a5 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/SemanticEventProducer.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/SemanticEventProducer.java
@@ -36,7 +36,7 @@ import java.util.List;
import java.util.stream.Collectors;
@Path("/v2/users/{username}/streams")
-public class SemanticEventProducer extends AbstractRestInterface implements
IPipelineElement {
+public class SemanticEventProducer extends AbstractRestResource implements
IPipelineElement {
@GET
@Path("/available")
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Setup.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Setup.java
index fdc8fa2..e7c45a9 100644
--- a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Setup.java
+++ b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Setup.java
@@ -33,7 +33,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/setup")
-public class Setup extends AbstractRestInterface {
+public class Setup extends AbstractRestResource {
@GET
@Path("/configured")
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/User.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/User.java
index 0cbc466..b53e4b1 100644
--- a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/User.java
+++ b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/User.java
@@ -29,7 +29,7 @@ import javax.ws.rs.core.Response;
import java.util.stream.Collectors;
@Path("/v2/users/{email}")
-public class User extends AbstractRestInterface {
+public class User extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Version.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Version.java
index 58e844c..1bacd77 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Version.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Version.java
@@ -27,7 +27,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/info")
-public class Version extends AbstractRestInterface {
+public class Version extends AbstractRestResource {
@GET
@Path("/versions")
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/VirtualSensor.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/VirtualSensor.java
index c5ced66..07a70d3 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/VirtualSensor.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/VirtualSensor.java
@@ -26,7 +26,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/users/{username}/block")
-public class VirtualSensor extends AbstractRestInterface {
+public class VirtualSensor extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Visualization.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Visualization.java
index 715ac2e..1bd075e 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Visualization.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/Visualization.java
@@ -25,7 +25,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/visualizations")
-public class Visualization extends AbstractRestInterface {
+public class Visualization extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/AbstractDashboardResource.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/AbstractDashboardResource.java
index 96ede46..e8df60e 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/AbstractDashboardResource.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/AbstractDashboardResource.java
@@ -19,14 +19,14 @@
package org.apache.streampipes.rest.impl.dashboard;
import org.apache.streampipes.model.dashboard.DashboardModel;
-import org.apache.streampipes.rest.impl.AbstractRestInterface;
+import org.apache.streampipes.rest.impl.AbstractRestResource;
import org.apache.streampipes.storage.api.IDashboardStorage;
import javax.ws.rs.*;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
-public abstract class AbstractDashboardResource extends AbstractRestInterface {
+public abstract class AbstractDashboardResource extends AbstractRestResource {
@GET
@Produces(MediaType.APPLICATION_JSON)
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/DashboardWidget.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/DashboardWidget.java
index f7d03ed..d3809ed 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/DashboardWidget.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/DashboardWidget.java
@@ -19,7 +19,7 @@
package org.apache.streampipes.rest.impl.dashboard;
import org.apache.streampipes.model.dashboard.DashboardWidgetModel;
-import org.apache.streampipes.rest.impl.AbstractRestInterface;
+import org.apache.streampipes.rest.impl.AbstractRestResource;
import org.apache.streampipes.rest.shared.annotation.JacksonSerialized;
import org.apache.streampipes.storage.api.IDashboardWidgetStorage;
@@ -28,7 +28,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/users/{username}/dashboard/widgets")
-public class DashboardWidget extends AbstractRestInterface {
+public class DashboardWidget extends AbstractRestResource {
@GET
@JacksonSerialized
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/VisualizablePipeline.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/VisualizablePipeline.java
index 0eb438e..a680841 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/VisualizablePipeline.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/dashboard/VisualizablePipeline.java
@@ -18,7 +18,7 @@
package org.apache.streampipes.rest.impl.dashboard;
-import org.apache.streampipes.rest.impl.AbstractRestInterface;
+import org.apache.streampipes.rest.impl.AbstractRestResource;
import org.apache.streampipes.rest.shared.annotation.JacksonSerialized;
import org.apache.streampipes.storage.api.IVisualizablePipelineStorage;
@@ -32,7 +32,7 @@ import java.util.List;
import java.util.Optional;
@Path("/v2/users/{username}/dashboard/pipelines")
-public class VisualizablePipeline extends AbstractRestInterface {
+public class VisualizablePipeline extends AbstractRestResource {
@GET
@JacksonSerialized
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeNoUserResourceV3.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeNoUserResourceV3.java
index 69eca8a..0736e99 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeNoUserResourceV3.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeNoUserResourceV3.java
@@ -20,7 +20,7 @@ package org.apache.streampipes.rest.impl.datalake;
import org.apache.streampipes.dataexplorer.DataLakeNoUserManagementV3;
import org.apache.streampipes.model.schema.EventSchema;
-import org.apache.streampipes.rest.impl.AbstractRestInterface;
+import org.apache.streampipes.rest.impl.AbstractRestResource;
import org.apache.streampipes.rest.shared.annotation.JacksonSerialized;
import javax.ws.rs.*;
@@ -28,7 +28,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v3/noauth/datalake")
-public class DataLakeNoUserResourceV3 extends AbstractRestInterface {
+public class DataLakeNoUserResourceV3 extends AbstractRestResource {
private DataLakeNoUserManagementV3 dataLakeManagement;
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeWidgetResource.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeWidgetResource.java
index fb41ab7..9a87047 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeWidgetResource.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/datalake/DataLakeWidgetResource.java
@@ -19,7 +19,7 @@
package org.apache.streampipes.rest.impl.datalake;
import org.apache.streampipes.model.datalake.DataExplorerWidgetModel;
-import org.apache.streampipes.rest.impl.AbstractRestInterface;
+import org.apache.streampipes.rest.impl.AbstractRestResource;
import org.apache.streampipes.rest.shared.annotation.JacksonSerialized;
import org.apache.streampipes.storage.api.IDataExplorerWidgetStorage;
@@ -28,7 +28,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v3/users/{username}/datalake/dashboard/widgets")
-public class DataLakeWidgetResource extends AbstractRestInterface {
+public class DataLakeWidgetResource extends AbstractRestResource {
@GET
@JacksonSerialized
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/FileServingResource.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/FileServingResource.java
index df95235..5467889 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/FileServingResource.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/FileServingResource.java
@@ -18,7 +18,7 @@
package org.apache.streampipes.rest.impl.nouser;
import org.apache.streampipes.manager.file.FileManager;
-import org.apache.streampipes.rest.impl.AbstractRestInterface;
+import org.apache.streampipes.rest.impl.AbstractRestResource;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
@@ -28,7 +28,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/noauth/files")
-public class FileServingResource extends AbstractRestInterface {
+public class FileServingResource extends AbstractRestResource {
@GET
@Path("/{filename}")
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/PipelineElementImportNoUser.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/PipelineElementImportNoUser.java
index 614e83e..d607a0e 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/PipelineElementImportNoUser.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/PipelineElementImportNoUser.java
@@ -23,7 +23,7 @@ import org.apache.streampipes.manager.storage.UserService;
import org.apache.streampipes.model.message.Message;
import org.apache.streampipes.model.message.Notification;
import org.apache.streampipes.model.message.NotificationType;
-import org.apache.streampipes.rest.impl.AbstractRestInterface;
+import org.apache.streampipes.rest.impl.AbstractRestResource;
import
org.apache.streampipes.storage.api.IPipelineElementDescriptionStorageCache;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -35,7 +35,7 @@ import javax.ws.rs.core.Response;
import javax.ws.rs.core.UriInfo;
@Path("/v2/noauth/users/{username}/element")
-public class PipelineElementImportNoUser extends AbstractRestInterface {
+public class PipelineElementImportNoUser extends AbstractRestResource {
private static final Logger logger =
LoggerFactory.getLogger(PipelineElementImportNoUser.class);
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/PipelineNoUserResource.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/PipelineNoUserResource.java
index 2a9e563..dfc0d79 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/PipelineNoUserResource.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/impl/nouser/PipelineNoUserResource.java
@@ -20,7 +20,7 @@ package org.apache.streampipes.rest.impl.nouser;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-import org.apache.streampipes.rest.impl.AbstractRestInterface;
+import org.apache.streampipes.rest.impl.AbstractRestResource;
import org.apache.streampipes.rest.management.PipelineManagement;
import org.apache.streampipes.rest.shared.annotation.GsonWithIds;
import org.apache.streampipes.rest.shared.annotation.NoAuthenticationRequired;
@@ -33,7 +33,7 @@ import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
@Path("/v2/pipelines")
-public class PipelineNoUserResource extends AbstractRestInterface {
+public class PipelineNoUserResource extends AbstractRestResource {
private static final Logger logger =
LoggerFactory.getLogger(PipelineNoUserResource.class);
diff --git
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/management/PipelineManagement.java
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/management/PipelineManagement.java
index 446953f..64d1176 100644
---
a/streampipes-rest/src/main/java/org/apache/streampipes/rest/management/PipelineManagement.java
+++
b/streampipes-rest/src/main/java/org/apache/streampipes/rest/management/PipelineManagement.java
@@ -23,11 +23,11 @@ import org.apache.streampipes.model.message.Notification;
import org.apache.streampipes.model.message.NotificationType;
import org.apache.streampipes.model.pipeline.Pipeline;
import org.apache.streampipes.model.pipeline.PipelineOperationStatus;
-import org.apache.streampipes.rest.impl.AbstractRestInterface;
+import org.apache.streampipes.rest.impl.AbstractRestResource;
import javax.ws.rs.core.Response;
-public class PipelineManagement extends AbstractRestInterface {
+public class PipelineManagement extends AbstractRestResource {
public Response stopPipeline(String pipelineId) {
try {
