Package org.springframework.modulith.events

Interface EventPublicationRepository

All Known Implementing Classes:
JdbcEventPublicationRepository, JpaEventPublicationRepository, MongoDbEventPublicationRepository
public interface EventPublicationRepository
Repository to store EventPublications.
Author:
Björn Kieling, Dmitry Belyaev, Oliver Drotbohm

  • Method Details

    • create

      EventPublication create(EventPublication publication)
      Persists the given EventPublication.
      Parameters:
      publication - must not be null.
      Returns:
      will never be null.

    • update

      EventPublication update(CompletableEventPublication publication)
      Update the data store to mark the backing log entry as completed.
      Parameters:
      publication - must not be null.
      Returns:
      will never be null.

    • findIncompletePublications

      List<EventPublication> findIncompletePublications()
      Returns all EventPublication that have not been completed yet.
      Returns:
      will never be null.

    • findIncompletePublicationsByEventAndTargetIdentifier

      Optional<EventPublication> findIncompletePublicationsByEventAndTargetIdentifier(Object event, PublicationTargetIdentifier targetIdentifier)
      Return the incomplete EventPublication for the given serialized event and listener identifier.
      Parameters:
      event - must not be null.
      targetIdentifier - must not be null.
      Returns:
      will never be null.

    • deleteCompletedPublications

      void deleteCompletedPublications()
      Deletes all publications that were already marked as completed.