public abstract class AbstractApplicationEventStoreMixin extends Object implements ApplicationEventStore, ApplicationEventStream, ApplicationEventStoreActivation
ApplicationEventStoreActivation.Activator
Modifier and Type | Field and Description |
---|---|
protected ValueType |
domainEventType |
protected Identity |
identity |
protected Lock |
lock |
protected org.slf4j.Logger |
logger |
protected Module |
module |
protected ValueType |
transactionEventsType |
Constructor and Description |
---|
AbstractApplicationEventStoreMixin() |
Modifier and Type | Method and Description |
---|---|
void |
activateApplicationEventStore() |
protected abstract void |
commit() |
protected void |
lock()
Fix for this bug:
http://bugs.sun.com/bugdatabase/view_bug.do?
|
void |
passivateApplicationEventStore() |
void |
registerListener(Output<TransactionApplicationEvents,? extends Throwable> listener) |
protected abstract void |
rollback() |
TransactionApplicationEvents |
storeEvents(Iterable<ApplicationEvent> events) |
protected abstract void |
storeEvents(TransactionApplicationEvents transactionDomain) |
void |
unregisterListener(Output<TransactionApplicationEvents,? extends Throwable> listener) |
protected org.slf4j.Logger logger
protected ValueType domainEventType
protected ValueType transactionEventsType
protected Lock lock
@Structure protected Module module
public void activateApplicationEventStore() throws Exception
activateApplicationEventStore
in interface ApplicationEventStoreActivation
Exception
public void passivateApplicationEventStore() throws Exception
passivateApplicationEventStore
in interface ApplicationEventStoreActivation
Exception
public TransactionApplicationEvents storeEvents(Iterable<ApplicationEvent> events) throws IOException
storeEvents
in interface ApplicationEventStore
IOException
public void registerListener(Output<TransactionApplicationEvents,? extends Throwable> listener)
registerListener
in interface ApplicationEventStream
public void unregisterListener(Output<TransactionApplicationEvents,? extends Throwable> listener)
unregisterListener
in interface ApplicationEventStream
protected abstract void rollback() throws IOException
IOException
protected abstract void commit() throws IOException
IOException
protected abstract void storeEvents(TransactionApplicationEvents transactionDomain) throws IOException
IOException
protected void lock()