|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.openjpa.lib.util.concurrent.AbstractConcurrentEventManager org.apache.openjpa.event.RemoteCommitEventManager
public class RemoteCommitEventManager
Manager that can be used to track and notify
RemoteCommitListener
s on remote commit events. If remote events
are enabled, this manager should be installed as a transaction listener on
all brokers so that it knows when commits are made.
Field Summary |
---|
Fields inherited from class org.apache.openjpa.lib.util.concurrent.AbstractConcurrentEventManager |
---|
_listeners |
Constructor Summary | |
---|---|
RemoteCommitEventManager(OpenJPAConfiguration conf)
Constructor. |
Method Summary | |
---|---|
void |
addInternalListener(RemoteCommitListener listen)
Adds an OpenJPA-internal listener to this RemoteCommitEventManager. |
void |
addListener(RemoteCommitListener listen)
|
void |
afterCommit(TransactionEvent event)
Notification that a transaction has successfully committed. |
void |
afterCommitComplete(TransactionEvent event)
Notification that a transaction has successfully committed and the transaction is no longer active. |
void |
afterRollback(TransactionEvent event)
Notification that a transaction has been rolled back. |
void |
afterRollbackComplete(TransactionEvent event)
Notification that a transaction has been rolled back and the transaction is no longer active. |
void |
afterStateTransitions(TransactionEvent event)
Notification that state transitions are complete. |
boolean |
areRemoteEventsEnabled()
Return true if remote events are enabled. |
void |
beforeCommit(TransactionEvent event)
Notification that the next flush is for the transaction commit. |
void |
close()
Close this manager and all registered listeners. |
protected void |
fireEvent(Object event,
Object listener)
Implement this method to fire the given event to the given listener. |
void |
fireLocalStaleNotification(Object oid)
Fire an event to local listeners only notifying them of a detected stale record. |
RemoteCommitProvider |
getRemoteCommitProvider()
Return the RemoteCommitProvider that this manager uses. |
boolean |
getTransmitPersistedObjectIds()
Whether the oids of added instances will be transmitted. |
void |
setTransmitPersistedObjectIds(boolean transmit)
Whether the oids of added instances will be transmitted. |
Methods inherited from class org.apache.openjpa.lib.util.concurrent.AbstractConcurrentEventManager |
---|
addListener, fireEvent, getListeners, hasListener, hasListeners, isFailFast, newListenerCollection, removeListener, setFailFast |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public RemoteCommitEventManager(OpenJPAConfiguration conf)
Method Detail |
---|
public boolean areRemoteEventsEnabled()
public RemoteCommitProvider getRemoteCommitProvider()
RemoteCommitProvider
that this manager uses.
public boolean getTransmitPersistedObjectIds()
public void setTransmitPersistedObjectIds(boolean transmit)
public void addInternalListener(RemoteCommitListener listen)
addListener(org.apache.openjpa.event.RemoteCommitListener)
. This means that the external listeners can
rely on internal caches and data structures being up-to-date by the
time that they are invoked.
public void addListener(RemoteCommitListener listen)
public void close()
close
in interface Closeable
protected void fireEvent(Object event, Object listener)
AbstractConcurrentEventManager
fireEvent
in class AbstractConcurrentEventManager
public void fireLocalStaleNotification(Object oid)
public void afterCommit(TransactionEvent event)
EndTransactionListener
afterCommit
in interface EndTransactionListener
TransactionEvent.AFTER_COMMIT
public void beforeCommit(TransactionEvent event)
EndTransactionListener
beforeCommit
in interface EndTransactionListener
TransactionEvent.BEFORE_COMMIT
public void afterRollback(TransactionEvent event)
EndTransactionListener
afterRollback
in interface EndTransactionListener
TransactionEvent.AFTER_ROLLBACK
public void afterCommitComplete(TransactionEvent event)
EndTransactionListener
afterCommitComplete
in interface EndTransactionListener
TransactionEvent.AFTER_COMMIT_COMPLETE
public void afterRollbackComplete(TransactionEvent event)
EndTransactionListener
afterRollbackComplete
in interface EndTransactionListener
TransactionEvent.AFTER_ROLLBACK_COMPLETE
public void afterStateTransitions(TransactionEvent event)
EndTransactionListener
afterStateTransitions
in interface EndTransactionListener
TransactionEvent.AFTER_STATE_TRANSITIONS
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |