|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.openjpa.event.AbstractRemoteCommitProvider org.apache.openjpa.event.TCPRemoteCommitProvider
public class TCPRemoteCommitProvider
TCP-based implementation of RemoteCommitProvider
that
listens for object modifications and propagates those changes to
other RemoteCommitProviders over TCP sockets.
Field Summary |
---|
Fields inherited from class org.apache.openjpa.event.AbstractRemoteCommitProvider |
---|
eventManager, log |
Constructor Summary | |
---|---|
TCPRemoteCommitProvider()
|
Method Summary | |
---|---|
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 |
endConfiguration()
Subclasses that need to perform actions in Configurable.endConfiguration() must invoke this method. |
int |
getMaxActive()
The maximum number of sockets that this provider can simetaneously open to each peer in the cluster. |
int |
getMaxIdle()
The number of idle sockets that this provider can keep open to each peer in the cluster. |
int |
getNumBroadcastThreads()
The number of worker threads that are used for transmitting packets to peers in the cluster. |
int |
getPort()
The port that this provider should listen on. |
int |
getRecoveryTimeMillis()
The number of milliseconds to wait before retrying to reconnect to a peer after it becomes unreachable. |
void |
setAddresses(String names)
Sets the list of addresses of peers to which this provider will send events to. |
void |
setMaxActive(int maxActive)
The maximum number of sockets that this provider can simetaneously open to each peer in the cluster. |
void |
setMaxIdle(int maxIdle)
The number of idle sockets that this provider can keep open to each peer in the cluster. |
void |
setNumBroadcastThreads(int numBroadcastThreads)
The number of worker threads that are used for transmitting packets to peers in the cluster. |
void |
setPort(int port)
The port that this provider should listen on. |
void |
setRecoveryTimeMillis(int recoverytime)
The number of milliseconds to wait before retrying to reconnect to a peer after it becomes unreachable. |
Methods inherited from class org.apache.openjpa.event.AbstractRemoteCommitProvider |
---|
fireEvent, setConfiguration, setRemoteCommitEventManager, startConfiguration |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface org.apache.openjpa.lib.conf.Configurable |
---|
setConfiguration, startConfiguration |
Constructor Detail |
---|
public TCPRemoteCommitProvider() throws UnknownHostException
UnknownHostException
Method Detail |
---|
public int getPort()
public void setPort(int port)
public void setRecoveryTimeMillis(int recoverytime)
public int getRecoveryTimeMillis()
public void setMaxActive(int maxActive)
public int getMaxActive()
public void setMaxIdle(int maxIdle)
public int getMaxIdle()
public void setNumBroadcastThreads(int numBroadcastThreads)
public int getNumBroadcastThreads()
public void setAddresses(String names) throws UnknownHostException
names
list in the form of "myhost1:portA;myhost2:portB".
UnknownHostException
public void endConfiguration()
Configurable.endConfiguration()
must invoke this method.
endConfiguration
in interface Configurable
endConfiguration
in class AbstractRemoteCommitProvider
public void broadcast(RemoteCommitEvent event)
RemoteCommitProvider
broadcast
in interface RemoteCommitProvider
public void close()
RemoteCommitProvider
close
in interface RemoteCommitProvider
close
in interface Closeable
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |