diff --git a/xwiki-platform-core/xwiki-platform-eventstream/xwiki-platform-eventstream-stores/xwiki-platform-eventstream-store-hibernate/src/main/java/org/xwiki/eventstream/store/internal/AbstractLegacyEventStore.java b/xwiki-platform-core/xwiki-platform-eventstream/xwiki-platform-eventstream-stores/xwiki-platform-eventstream-store-hibernate/src/main/java/org/xwiki/eventstream/store/internal/AbstractLegacyEventStore.java index 740f7095517e429b23e4c06e54013b4699dbb118..ba89042ea6ac112f0882af8080d9c4959d601e7a 100644 --- a/xwiki-platform-core/xwiki-platform-eventstream/xwiki-platform-eventstream-stores/xwiki-platform-eventstream-store-hibernate/src/main/java/org/xwiki/eventstream/store/internal/AbstractLegacyEventStore.java +++ b/xwiki-platform-core/xwiki-platform-eventstream/xwiki-platform-eventstream-stores/xwiki-platform-eventstream-store-hibernate/src/main/java/org/xwiki/eventstream/store/internal/AbstractLegacyEventStore.java @@ -73,7 +73,7 @@ protected Optional<Event> syncDeleteEvent(String eventId) throws EventStreamExce } @Override - public Optional<Event> syncDeleteEvent(Event event) throws EventStreamException + protected Optional<Event> syncDeleteEvent(Event event) throws EventStreamException { Optional<Event> existingEvent = getEvent(event.getId()); @@ -85,7 +85,7 @@ public Optional<Event> syncDeleteEvent(Event event) throws EventStreamException } @Override - public EventStatus syncSaveEventStatus(EventStatus status) throws EventStreamException + protected EventStatus syncSaveEventStatus(EventStatus status) throws EventStreamException { try { this.eventStatusManager.saveEventStatus(status); @@ -97,14 +97,14 @@ public EventStatus syncSaveEventStatus(EventStatus status) throws EventStreamExc } @Override - public EntityEvent syncSaveMailEntityEvent(EntityEvent event) throws EventStreamException + protected EntityEvent syncSaveMailEntityEvent(EntityEvent event) throws EventStreamException { // Unsupported return event; } @Override - public Optional<EventStatus> syncDeleteEventStatus(EventStatus status) throws EventStreamException + protected Optional<EventStatus> syncDeleteEventStatus(EventStatus status) throws EventStreamException { try { this.eventStatusManager.deleteEventStatus(status); diff --git a/xwiki-platform-core/xwiki-platform-eventstream/xwiki-platform-eventstream-stores/xwiki-platform-eventstream-store-hibernate/src/main/java/org/xwiki/eventstream/store/internal/LegacyEventStatus.java b/xwiki-platform-core/xwiki-platform-eventstream/xwiki-platform-eventstream-stores/xwiki-platform-eventstream-store-hibernate/src/main/java/org/xwiki/eventstream/store/internal/LegacyEventStatus.java index f7824b5804796473f35ad503c7c9d4f9fc63bd32..59ccf180e5dcf652311f8dd8569b4673f6d2f561 100644 --- a/xwiki-platform-core/xwiki-platform-eventstream/xwiki-platform-eventstream-stores/xwiki-platform-eventstream-store-hibernate/src/main/java/org/xwiki/eventstream/store/internal/LegacyEventStatus.java +++ b/xwiki-platform-core/xwiki-platform-eventstream/xwiki-platform-eventstream-stores/xwiki-platform-eventstream-store-hibernate/src/main/java/org/xwiki/eventstream/store/internal/LegacyEventStatus.java @@ -23,8 +23,6 @@ import org.xwiki.eventstream.EventStatus; import org.xwiki.text.StringUtils; -import java.io.Serializable; - /** * A Legacy Event Status is the equivalent of {@link EventStatus} for {@link LegacyEvent}. * @@ -33,7 +31,7 @@ * @since 11.1RC1 * @version $Id$ */ -public class LegacyEventStatus implements Serializable +public class LegacyEventStatus { private LegacyEvent activityEvent; diff --git a/xwiki-platform-core/xwiki-platform-eventstream/xwiki-platform-eventstream-stores/xwiki-platform-eventstream-store-hibernate/src/main/java/org/xwiki/eventstream/store/internal/LegacyEventStatusManager.java b/xwiki-platform-core/xwiki-platform-eventstream/xwiki-platform-eventstream-stores/xwiki-platform-eventstream-store-hibernate/src/main/java/org/xwiki/eventstream/store/internal/LegacyEventStatusManager.java index bb3393cf436d115aa1e43812a27d4d996f7221f8..8903032c4c585107b3fb91aa5b2797c368ef0629 100644 --- a/xwiki-platform-core/xwiki-platform-eventstream/xwiki-platform-eventstream-stores/xwiki-platform-eventstream-store-hibernate/src/main/java/org/xwiki/eventstream/store/internal/LegacyEventStatusManager.java +++ b/xwiki-platform-core/xwiki-platform-eventstream/xwiki-platform-eventstream-stores/xwiki-platform-eventstream-store-hibernate/src/main/java/org/xwiki/eventstream/store/internal/LegacyEventStatusManager.java @@ -37,10 +37,7 @@ import org.xwiki.eventstream.EventStatusManager; import org.xwiki.eventstream.EventStreamException; import org.xwiki.eventstream.internal.DefaultEventStatus; -import org.xwiki.eventstream.internal.events.EventStatusAddOrUpdatedEvent; -import org.xwiki.eventstream.internal.events.EventStatusDeletedEvent; import org.xwiki.model.namespace.WikiNamespace; -import org.xwiki.observation.ObservationManager; import org.xwiki.query.Query; import org.xwiki.query.QueryManager; import org.xwiki.wiki.descriptor.WikiDescriptorManager; @@ -74,9 +71,6 @@ public class LegacyEventStatusManager implements EventStatusManager @Inject private WikiDescriptorManager wikiDescriptorManager; - @Inject - private ObservationManager observation; - @Inject private NamespaceContextExecutor namespaceContextExecutor; @@ -201,7 +195,6 @@ private void saveEventStatusInStore(LegacyEventStatus eventStatus, String wikiId throw new EventStreamException(e); } - this.observation.notify(new EventStatusAddOrUpdatedEvent(), eventStatus); return null; }); } @@ -222,7 +215,6 @@ private void deleteEventStatusFromStore(LegacyEventStatus eventStatus, String wi throw new EventStreamException(e); } - this.observation.notify(new EventStatusAddOrUpdatedEvent(), eventStatus); return null; }); } @@ -259,7 +251,6 @@ private void deleteAllForEntityInStore(Date startDate, String entityId, String w throw new EventStreamException(e); } - this.observation.notify(new EventStatusDeletedEvent(), null); return null; }); }