io.eventuate.javaclient.jdbc

Class AbstractJdbcAggregateCrud

java.lang.Object

io.eventuate.javaclient.jdbc.AbstractJdbcAggregateCrud

All Implemented Interfaces:

io.eventuate.javaclient.commonimpl.sync.AggregateCrud

Direct Known Subclasses:

EventuateEmbeddedTestAggregateStore

public abstract class AbstractJdbcAggregateCrud
extends java.lang.Object
implements io.eventuate.javaclient.commonimpl.sync.AggregateCrud

Field Summary

Fields

Modifier and Type	Field and Description
protected EventuateJdbcAccess	eventuateJdbcAccess

Constructor Summary

Constructors

Constructor and Description
AbstractJdbcAggregateCrud(EventuateJdbcAccess eventuateJdbcAccess)

Method Summary

Modifier and Type	Method and Description
<T extends Aggregate<T>> io.eventuate.javaclient.commonimpl.LoadedEvents	find(java.lang.String aggregateType, java.lang.String entityId, java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudFindOptions> findOptions)
protected void	publish(PublishableEvents publishableEvents)
io.eventuate.javaclient.commonimpl.EntityIdVersionAndEventIds	save(java.lang.String aggregateType, java.util.List<io.eventuate.javaclient.commonimpl.EventTypeAndData> events, java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudSaveOptions> options)
io.eventuate.javaclient.commonimpl.EntityIdVersionAndEventIds	update(EntityIdAndType entityIdAndType, io.eventuate.common.id.Int128 entityVersion, java.util.List<io.eventuate.javaclient.commonimpl.EventTypeAndData> events, java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudUpdateOptions> updateOptions)

Methods inherited from class java.lang.Object

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

Field Detail

eventuateJdbcAccess

protected EventuateJdbcAccess eventuateJdbcAccess

Constructor Detail

AbstractJdbcAggregateCrud

public AbstractJdbcAggregateCrud(EventuateJdbcAccess eventuateJdbcAccess)

Method Detail

publish

protected void publish(PublishableEvents publishableEvents)

save

public io.eventuate.javaclient.commonimpl.EntityIdVersionAndEventIds save(java.lang.String aggregateType,
                                                                          java.util.List<io.eventuate.javaclient.commonimpl.EventTypeAndData> events,
                                                                          java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudSaveOptions> options)

Specified by:

save in interface io.eventuate.javaclient.commonimpl.sync.AggregateCrud

find

public <T extends Aggregate<T>> io.eventuate.javaclient.commonimpl.LoadedEvents find(java.lang.String aggregateType,
                                                                                     java.lang.String entityId,
                                                                                     java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudFindOptions> findOptions)

Specified by:

find in interface io.eventuate.javaclient.commonimpl.sync.AggregateCrud

update

public io.eventuate.javaclient.commonimpl.EntityIdVersionAndEventIds update(EntityIdAndType entityIdAndType,
                                                                            io.eventuate.common.id.Int128 entityVersion,
                                                                            java.util.List<io.eventuate.javaclient.commonimpl.EventTypeAndData> events,
                                                                            java.util.Optional<io.eventuate.javaclient.commonimpl.AggregateCrudUpdateOptions> updateOptions)

Specified by:

update in interface io.eventuate.javaclient.commonimpl.sync.AggregateCrud