Package org.springframework.modulith.events.jdbc

Class JdbcEventPublicationRepository

java.lang.Object

org.springframework.modulith.events.jdbc.JdbcEventPublicationRepository

All Implemented Interfaces:

EventPublicationRepository

class JdbcEventPublicationRepository
extends Object
implements EventPublicationRepository

JDBC-based repository to store EventPublications.

Author:

Dmitry Belyaev, Björn Kieling, Oliver Drotbohm

Constructor Summary

Constructors

Constructor	Description
JdbcEventPublicationRepository(JdbcOperations operations, EventSerializer serializer, DatabaseType databaseType)	Creates a new JdbcEventPublicationRepository for the given JdbcOperations, EventSerializer and DatabaseType.

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.
void	deleteCompletedPublicationsBefore(Instant instant)	Deletes all publication that were already marked as completed with a completion date before the given one.
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.
void	markCompleted(Object event, PublicationTargetIdentifier identifier, Instant completionDate)	Marks the publication for the given event and PublicationTargetIdentifier to be completed at the given Instant.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.modulith.events.core.EventPublicationRepository

markCompleted

Constructor Details

JdbcEventPublicationRepository

public JdbcEventPublicationRepository(JdbcOperations operations,
 EventSerializer serializer,
 DatabaseType databaseType)

Creates a new JdbcEventPublicationRepository for the given JdbcOperations, EventSerializer and DatabaseType.

Parameters:

operations - must not be null.

serializer - must not be null.

databaseType - 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.

markCompleted

@Transactional
public void markCompleted(Object event,
 PublicationTargetIdentifier identifier,
 Instant completionDate)

Description copied from interface: EventPublicationRepository

Marks the publication for the given event and PublicationTargetIdentifier to be completed at the given Instant.

Specified by:

markCompleted in interface EventPublicationRepository

Parameters:

event - must not be null.

identifier - must not be null.

completionDate - must not 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.

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.

deleteCompletedPublications

public void deleteCompletedPublications()

Description copied from interface: EventPublicationRepository

Deletes all publications that were already marked as completed.

Specified by:

deleteCompletedPublications in interface EventPublicationRepository

deleteCompletedPublicationsBefore

public void deleteCompletedPublicationsBefore(Instant instant)

Description copied from interface: EventPublicationRepository

Deletes all publication that were already marked as completed with a completion date before the given one.

Specified by:

deleteCompletedPublicationsBefore in interface EventPublicationRepository

Parameters:

instant - must not be null.