io.eventuate.javaclient.spring.jdbc

Class EventuateEmbeddedTestAggregateStore

java.lang.Object

io.eventuate.javaclient.spring.jdbc.AbstractJdbcAggregateCrud

io.eventuate.javaclient.spring.jdbc.EventuateEmbeddedTestAggregateStore

All Implemented Interfaces:

io.eventuate.javaclient.commonimpl.sync.AggregateCrud, io.eventuate.javaclient.commonimpl.sync.AggregateEvents

public class EventuateEmbeddedTestAggregateStore
extends AbstractJdbcAggregateCrud
implements io.eventuate.javaclient.commonimpl.sync.AggregateEvents

Field Summary

Fields inherited from class io.eventuate.javaclient.spring.jdbc.AbstractJdbcAggregateCrud

eventuateJdbcAccess

Constructor Summary

Constructors

Constructor and Description
EventuateEmbeddedTestAggregateStore(EventuateJdbcAccess eventuateJdbcAccess)

Method Summary

Modifier and Type	Method and Description
protected void	publish(PublishableEvents publishableEvents)
void	subscribe(java.lang.String subscriberId, java.util.Map<java.lang.String,java.util.Set<java.lang.String>> aggregatesAndEvents, SubscriberOptions options, java.util.function.Function<io.eventuate.javaclient.commonimpl.SerializedEvent,java.util.concurrent.CompletableFuture<?>> handler)

Methods inherited from class io.eventuate.javaclient.spring.jdbc.AbstractJdbcAggregateCrud

find, save, update

Methods inherited from class java.lang.Object

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

Constructor Detail

EventuateEmbeddedTestAggregateStore

public EventuateEmbeddedTestAggregateStore(EventuateJdbcAccess eventuateJdbcAccess)

Method Detail

publish

protected void publish(PublishableEvents publishableEvents)

Overrides:

publish in class AbstractJdbcAggregateCrud

subscribe

public void subscribe(java.lang.String subscriberId,
                      java.util.Map<java.lang.String,java.util.Set<java.lang.String>> aggregatesAndEvents,
                      SubscriberOptions options,
                      java.util.function.Function<io.eventuate.javaclient.commonimpl.SerializedEvent,java.util.concurrent.CompletableFuture<?>> handler)

Specified by:

subscribe in interface io.eventuate.javaclient.commonimpl.sync.AggregateEvents