Do not send DistributionSetDeletedEvent twice (#1478)
This commit is contained in:
@@ -335,10 +335,6 @@ public class JpaDistributionSetManagement implements DistributionSetManagement {
|
|||||||
// handle the empty list
|
// handle the empty list
|
||||||
distributionSetRepository.deleteAllById(toHardDelete);
|
distributionSetRepository.deleteAllById(toHardDelete);
|
||||||
}
|
}
|
||||||
|
|
||||||
afterCommit.afterCommit(() -> distributionSetIDs.forEach(dsId -> eventPublisherHolder.getEventPublisher()
|
|
||||||
.publishEvent(new DistributionSetDeletedEvent(tenantAware.getCurrentTenant(), dsId,
|
|
||||||
JpaDistributionSet.class, eventPublisherHolder.getApplicationId()))));
|
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
|
|||||||
@@ -9,8 +9,6 @@
|
|||||||
*/
|
*/
|
||||||
package org.eclipse.hawkbit.repository.jpa.repository;
|
package org.eclipse.hawkbit.repository.jpa.repository;
|
||||||
|
|
||||||
import java.util.List;
|
|
||||||
|
|
||||||
import javax.persistence.EntityManager;
|
import javax.persistence.EntityManager;
|
||||||
|
|
||||||
import org.eclipse.hawkbit.repository.jpa.model.JpaDistributionSetType;
|
import org.eclipse.hawkbit.repository.jpa.model.JpaDistributionSetType;
|
||||||
|
|||||||
Reference in New Issue
Block a user