public class RemoteCommitEventManager extends AbstractConcurrentEventManager implements EndTransactionListener, Closeable
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._listeners
Constructor and Description |
---|
RemoteCommitEventManager(OpenJPAConfiguration conf)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
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.
|
addListener, fireEvent, getListeners, hasListener, hasListeners, isFailFast, newListenerCollection, removeListener, setFailFast
public RemoteCommitEventManager(OpenJPAConfiguration conf)
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()
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
Copyright © 2006–2022 Apache Software Foundation. All rights reserved.