Package org.apache.openjpa.event
Interface RemoteCommitProvider
-
- All Superinterfaces:
Closeable
- All Known Implementing Classes:
AbstractRemoteCommitProvider
,DynamicTCPRemoteCommitProvider
,JMSRemoteCommitProvider
,KubernetesTCPRemoteCommitProvider
,SingleJVMRemoteCommitProvider
,TCPRemoteCommitProvider
public interface RemoteCommitProvider extends Closeable
An entity that is responsible for communicating commit notification to otherRemoteCommitEventManager
s. Each event manager creates a remote commit provider, based on the values of theopenjpa.RemoteCommitProvider
configuration property. An adapter that implementsTransactionListener
is registered with eachBroker
. This adapter invokesbroadcast
, which is responsible for notifying other remote commit provider objects of the commit changes. Upon receiving a notification from a different remote commit provider, a provider must notify all local remote commit listeners via theRemoteCommitEventManager.fireEvent(java.lang.Object, java.lang.Object)
method. A remote commit provider must not fire remote events for commits that originated with a local broker.- Since:
- 0.2.5.0
- Author:
- Patrick Linskey
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
broadcast(RemoteCommitEvent event)
Notifies other remote event managers in this JVM and on other machines of changes to the cache.void
close()
Free the resources used by this provider.void
setRemoteCommitEventManager(RemoteCommitEventManager mgr)
Set the "owning" remote event manager to notify when remote events are received from remote sources.
-
-
-
Method Detail
-
setRemoteCommitEventManager
void setRemoteCommitEventManager(RemoteCommitEventManager mgr)
Set the "owning" remote event manager to notify when remote events are received from remote sources.
-
broadcast
void broadcast(RemoteCommitEvent event)
Notifies other remote event managers in this JVM and on other machines of changes to the cache. This method must not notify the event manager associated with the broker that originated this commit.
-
-