From 178b19316295876bafde649c5e7236bd052bee43 Mon Sep 17 00:00:00 2001 From: Michael Herdt Date: Fri, 17 Nov 2023 10:40:16 +0100 Subject: [PATCH] Do not send DistributionSetDeletedEvent twice (#1478) --- .../jpa/management/JpaDistributionSetManagement.java | 4 ---- .../jpa/repository/DistributionSetTypeRepository.java | 2 -- 2 files changed, 6 deletions(-) diff --git a/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/management/JpaDistributionSetManagement.java b/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/management/JpaDistributionSetManagement.java index c61c94c7a..f501affd0 100644 --- a/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/management/JpaDistributionSetManagement.java +++ b/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/management/JpaDistributionSetManagement.java @@ -335,10 +335,6 @@ public class JpaDistributionSetManagement implements DistributionSetManagement { // handle the empty list distributionSetRepository.deleteAllById(toHardDelete); } - - afterCommit.afterCommit(() -> distributionSetIDs.forEach(dsId -> eventPublisherHolder.getEventPublisher() - .publishEvent(new DistributionSetDeletedEvent(tenantAware.getCurrentTenant(), dsId, - JpaDistributionSet.class, eventPublisherHolder.getApplicationId())))); } @Override diff --git a/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/repository/DistributionSetTypeRepository.java b/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/repository/DistributionSetTypeRepository.java index 502db542b..2ab70e58d 100644 --- a/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/repository/DistributionSetTypeRepository.java +++ b/hawkbit-repository/hawkbit-repository-jpa/src/main/java/org/eclipse/hawkbit/repository/jpa/repository/DistributionSetTypeRepository.java @@ -9,8 +9,6 @@ */ package org.eclipse.hawkbit.repository.jpa.repository; -import java.util.List; - import javax.persistence.EntityManager; import org.eclipse.hawkbit.repository.jpa.model.JpaDistributionSetType;