Package org.springframework.modulith.events.jpa

Class JpaEventPublicationRepository

java.lang.Object

org.springframework.modulith.events.jpa.JpaEventPublicationRepository

All Implemented Interfaces:

EventPublicationRepository

class JpaEventPublicationRepository
extends Object
implements EventPublicationRepository

Repository to store EventPublications.

Author:

Oliver Drotbohm, Dmitry Belyaev, Björn Kieling

Constructor Summary

Constructors

Constructor	Description
JpaEventPublicationRepository(jakarta.persistence.EntityManager entityManager, EventSerializer serializer)	Creates a new JpaEventPublicationRepository for the given EntityManager and EventSerializer.

Method Summary

Modifier and Type	Method	Description
EventPublication	create(EventPublication publication)	Persists the given EventPublication.
void	deleteCompletedPublications()	Deletes all publications that were already marked as completed.
List<EventPublication>	findIncompletePublications()	Returns all EventPublication that have not been completed yet.
Optional<EventPublication>	findIncompletePublicationsByEventAndTargetIdentifier(Object event, PublicationTargetIdentifier targetIdentifier)	Return the incomplete EventPublication for the given serialized event and listener identifier.
EventPublication	update(CompletableEventPublication publication)	Update the data store to mark the backing log entry as completed.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

JpaEventPublicationRepository

public JpaEventPublicationRepository(jakarta.persistence.EntityManager entityManager,
 EventSerializer serializer)

Creates a new JpaEventPublicationRepository for the given EntityManager and EventSerializer.

Parameters:

entityManager - must not be null.

serializer - must not be null.

Method Details

create

@Transactional
public EventPublication create(EventPublication publication)

Description copied from interface: EventPublicationRepository

Persists the given EventPublication.

Specified by:

create in interface EventPublicationRepository

Parameters:

publication - must not be null.

Returns:

will never be null.

update

@Transactional
public EventPublication update(CompletableEventPublication publication)

Description copied from interface: EventPublicationRepository

Update the data store to mark the backing log entry as completed.

Specified by:

update in interface EventPublicationRepository

Parameters:

publication - must not be null.

Returns:

will never be null.

findIncompletePublications

@Transactional(readOnly=true)
public List<EventPublication> findIncompletePublications()

Description copied from interface: EventPublicationRepository

Returns all EventPublication that have not been completed yet.

Specified by:

findIncompletePublications in interface EventPublicationRepository

Returns:

will never be null.

findIncompletePublicationsByEventAndTargetIdentifier

@Transactional(readOnly=true)
public Optional<EventPublication> findIncompletePublicationsByEventAndTargetIdentifier(Object event,
 PublicationTargetIdentifier targetIdentifier)

Description copied from interface: EventPublicationRepository

Return the incomplete EventPublication for the given serialized event and listener identifier.

Specified by:

findIncompletePublicationsByEventAndTargetIdentifier in interface EventPublicationRepository

Parameters:

event - must not be null.

targetIdentifier - must not be null.

Returns:

will never be null.

deleteCompletedPublications

@Transactional
public void deleteCompletedPublications()

Description copied from interface: EventPublicationRepository

Deletes all publications that were already marked as completed.

Specified by:

deleteCompletedPublications in interface EventPublicationRepository