public abstract static class MemoryApplicationEventStoreService.MemoryStoreMixin extends AbstractApplicationEventStoreMixin implements ApplicationEventSource, ApplicationEventStoreActivation
ApplicationEventStoreActivation.ActivatordomainEventType, identity, lock, logger, module, transactionEventsType| Constructor and Description |
|---|
MemoryApplicationEventStoreService.MemoryStoreMixin() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
storeEvents(TransactionApplicationEvents transactionDomain) |
Input<TransactionApplicationEvents,IOException> |
transactionsAfter(long afterTimestamp,
long maxTransactions)
Get list of event transactions after the given timestamp.
|
Input<TransactionApplicationEvents,IOException> |
transactionsBefore(long beforeTimestamp,
long maxTransactions)
Get list of event transactions before the given timestamp.
|
activateApplicationEventStore, commit, lock, passivateApplicationEventStore, registerListener, rollback, storeEvents, unregisterListenerclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitactivateApplicationEventStore, passivateApplicationEventStorepublic MemoryApplicationEventStoreService.MemoryStoreMixin()
public Input<TransactionApplicationEvents,IOException> transactionsAfter(long afterTimestamp, long maxTransactions)
ApplicationEventSourceIf they are on the exact same timestamp, they will not be included.
The method uses the visitor pattern, so a visitor is sent in which is given each transaction, one at a time.
transactionsAfter in interface ApplicationEventSourceafterTimestamp - timestamp of transactionsmaxTransactions - maximum transactionspublic Input<TransactionApplicationEvents,IOException> transactionsBefore(long beforeTimestamp, long maxTransactions)
ApplicationEventSourceIf they are on the exact same timestamp, they will not be included.
The method uses the visitor pattern, so a visitor is sent in which is given each transaction, one at a time.
The transactions are sent to the visitor with the latest transaction first, i.e. walking backwards in the stream.
transactionsBefore in interface ApplicationEventSourcebeforeTimestamp - timestamp of transactionsmaxTransactions - maximum transactionsprotected void storeEvents(TransactionApplicationEvents transactionDomain) throws IOException
storeEvents in class AbstractApplicationEventStoreMixinIOException