From 1f7322c09c167b165649e1a56af5cfbabda9a3ee Mon Sep 17 00:00:00 2001 From: Volodymyr Babak Date: Tue, 24 Mar 2020 16:43:44 +0200 Subject: [PATCH] Build fix --- .../java/org/thingsboard/server/dao/edge/EdgeService.java | 2 +- .../server/dao/dashboard/DashboardServiceImpl.java | 2 ++ .../org/thingsboard/server/dao/edge/BaseEdgeService.java | 7 ++++--- 3 files changed, 7 insertions(+), 4 deletions(-) diff --git a/common/dao-api/src/main/java/org/thingsboard/server/dao/edge/EdgeService.java b/common/dao-api/src/main/java/org/thingsboard/server/dao/edge/EdgeService.java index cfb8deddac..80f9fd7120 100644 --- a/common/dao-api/src/main/java/org/thingsboard/server/dao/edge/EdgeService.java +++ b/common/dao-api/src/main/java/org/thingsboard/server/dao/edge/EdgeService.java @@ -5,7 +5,7 @@ * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * - * http://www.apache.org/licenses/LICENSE-2.0 + * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, diff --git a/dao/src/main/java/org/thingsboard/server/dao/dashboard/DashboardServiceImpl.java b/dao/src/main/java/org/thingsboard/server/dao/dashboard/DashboardServiceImpl.java index a09d6e1658..51ff47b93f 100644 --- a/dao/src/main/java/org/thingsboard/server/dao/dashboard/DashboardServiceImpl.java +++ b/dao/src/main/java/org/thingsboard/server/dao/dashboard/DashboardServiceImpl.java @@ -31,6 +31,7 @@ import org.thingsboard.server.common.data.id.EdgeId; import org.thingsboard.server.common.data.id.TenantId; import org.thingsboard.server.common.data.page.PageData; import org.thingsboard.server.common.data.page.PageLink; +import org.thingsboard.server.common.data.page.TimePageLink; import org.thingsboard.server.common.data.relation.EntityRelation; import org.thingsboard.server.common.data.relation.RelationTypeGroup; import org.thingsboard.server.dao.customer.CustomerDao; @@ -39,6 +40,7 @@ import org.thingsboard.server.dao.entity.AbstractEntityService; import org.thingsboard.server.dao.exception.DataValidationException; import org.thingsboard.server.dao.service.DataValidator; import org.thingsboard.server.dao.service.PaginatedRemover; +import org.thingsboard.server.dao.service.TimePaginatedRemover; import org.thingsboard.server.dao.service.Validator; import org.thingsboard.server.dao.tenant.TenantDao; diff --git a/dao/src/main/java/org/thingsboard/server/dao/edge/BaseEdgeService.java b/dao/src/main/java/org/thingsboard/server/dao/edge/BaseEdgeService.java index 7a8faa0bea..bae89d6231 100644 --- a/dao/src/main/java/org/thingsboard/server/dao/edge/BaseEdgeService.java +++ b/dao/src/main/java/org/thingsboard/server/dao/edge/BaseEdgeService.java @@ -20,6 +20,7 @@ import com.google.common.base.Function; import com.google.common.util.concurrent.FutureCallback; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; +import com.google.common.util.concurrent.MoreExecutors; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.cache.Cache; @@ -311,7 +312,7 @@ public class BaseEdgeService extends AbstractEntityService implements EdgeServic } } return Futures.successfulAsList(futures); - }); + }, MoreExecutors.directExecutor()); edges = Futures.transform(edges, new Function, List>() { @Nullable @@ -319,7 +320,7 @@ public class BaseEdgeService extends AbstractEntityService implements EdgeServic public List apply(@Nullable List edgeList) { return edgeList == null ? Collections.emptyList() : edgeList.stream().filter(edge -> query.getEdgeTypes().contains(edge.getType())).collect(Collectors.toList()); } - }); + }, MoreExecutors.directExecutor()); return edges; } @@ -333,7 +334,7 @@ public class BaseEdgeService extends AbstractEntityService implements EdgeServic edgeTypes -> { edgeTypes.sort(Comparator.comparing(EntitySubtype::getType)); return edgeTypes; - }); + }, MoreExecutors.directExecutor()); } @Override