public abstract static class MemoryApplicationEventStoreService.MemoryStoreMixin extends AbstractApplicationEventStoreMixin implements ApplicationEventSource, ApplicationEventStoreActivation
ApplicationEventStoreActivation.Activator
domainEventType, 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, unregisterListener
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
activateApplicationEventStore, passivateApplicationEventStore
public MemoryApplicationEventStoreService.MemoryStoreMixin()
public Input<TransactionApplicationEvents,IOException> transactionsAfter(long afterTimestamp, long maxTransactions)
ApplicationEventSource
If 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 ApplicationEventSource
afterTimestamp
- timestamp of transactionsmaxTransactions
- maximum transactionspublic Input<TransactionApplicationEvents,IOException> transactionsBefore(long beforeTimestamp, long maxTransactions)
ApplicationEventSource
If 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 ApplicationEventSource
beforeTimestamp
- timestamp of transactionsmaxTransactions
- maximum transactionsprotected void storeEvents(TransactionApplicationEvents transactionDomain) throws IOException
storeEvents
in class AbstractApplicationEventStoreMixin
IOException