com.fr.ehcache.cluster.peer

类 JGroupsCachePeer

java.lang.Object

com.fr.ehcache.cluster.peer.JGroupsCachePeer

所有已实现的接口:

com.fr.third.net.sf.ehcache.distribution.CachePeer, java.rmi.Remote

public class JGroupsCachePeer
extends java.lang.Object
implements com.fr.third.net.sf.ehcache.distribution.CachePeer

cache集群

发送集群消息

Handles CachePeerfunctions around a JGroups Channel and a CacheManager

版本:

$Revision$

作者:

Eric Dalquist

构造器概要

构造器

构造器和说明
JGroupsCachePeer(Channel channel, java.lang.String clusterName) Create a new CachePeer

方法概要

方法

限定符和类型	方法和说明
void	dispose() Shutdown the cache peer
java.util.List<?>	getElements(java.util.List keys)
java.util.List<Address>	getGroupMembership()
java.lang.String	getGuid()
java.util.List<?>	getKeys()
Address	getLocalAddress()
java.lang.String	getName()
java.util.List<Address>	getOtherGroupMembers()
com.fr.third.net.sf.ehcache.Element	getQuiet(java.io.Serializable key)
java.lang.String	getUrl()
java.lang.String	getUrlBase()
void	put(com.fr.third.net.sf.ehcache.Element element)
boolean	remove(java.io.Serializable key)
void	removeAll()
void	send(Address dest, java.util.List<JGroupEventMessage> eventMessages) Sends a list of JGroupEventMessages to the specified address, if no address is set the messages are sent to the entire group.
void	send(java.util.List eventMessages)

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

JGroupsCachePeer

public JGroupsCachePeer(Channel channel,
                java.lang.String clusterName)

Create a new CachePeer

方法详细资料

send

public void send(java.util.List eventMessages)
          throws java.rmi.RemoteException

指定者:

send 在接口中 com.fr.third.net.sf.ehcache.distribution.CachePeer

抛出:

java.rmi.RemoteException

getGroupMembership

public java.util.List<Address> getGroupMembership()

返回:

Get the address of all members in the cluster

getOtherGroupMembers

public java.util.List<Address> getOtherGroupMembers()

返回:

Get the address of all members in the cluster other than this one

getLocalAddress

public Address getLocalAddress()

返回:

Get the address of this machine in the cluster

dispose

public void dispose()

Shutdown the cache peer

send

public void send(Address dest,
        java.util.List<JGroupEventMessage> eventMessages)

Sends a list of JGroupEventMessages to the specified address, if no address is set the messages are sent to the entire group.

getElements

public java.util.List<?> getElements(java.util.List keys)
                              throws java.rmi.RemoteException

指定者:

getElements 在接口中 com.fr.third.net.sf.ehcache.distribution.CachePeer

抛出:

java.rmi.RemoteException

getGuid

public java.lang.String getGuid()
                         throws java.rmi.RemoteException

指定者:

getGuid 在接口中 com.fr.third.net.sf.ehcache.distribution.CachePeer

抛出:

java.rmi.RemoteException

getKeys

public java.util.List<?> getKeys()
                          throws java.rmi.RemoteException

指定者:

getKeys 在接口中 com.fr.third.net.sf.ehcache.distribution.CachePeer

抛出:

java.rmi.RemoteException

getName

public java.lang.String getName()
                         throws java.rmi.RemoteException

指定者:

getName 在接口中 com.fr.third.net.sf.ehcache.distribution.CachePeer

抛出:

java.rmi.RemoteException

getQuiet

public com.fr.third.net.sf.ehcache.Element getQuiet(java.io.Serializable key)
                                             throws java.rmi.RemoteException

指定者:

getQuiet 在接口中 com.fr.third.net.sf.ehcache.distribution.CachePeer

抛出:

java.rmi.RemoteException

getUrl

public java.lang.String getUrl()
                        throws java.rmi.RemoteException

指定者:

getUrl 在接口中 com.fr.third.net.sf.ehcache.distribution.CachePeer

抛出:

java.rmi.RemoteException

getUrlBase

public java.lang.String getUrlBase()
                            throws java.rmi.RemoteException

指定者:

getUrlBase 在接口中 com.fr.third.net.sf.ehcache.distribution.CachePeer

抛出:

java.rmi.RemoteException

put

public void put(com.fr.third.net.sf.ehcache.Element element)
         throws java.lang.IllegalArgumentException,
                java.lang.IllegalStateException,
                java.rmi.RemoteException

指定者:

put 在接口中 com.fr.third.net.sf.ehcache.distribution.CachePeer

抛出:

java.lang.IllegalArgumentException

java.lang.IllegalStateException

java.rmi.RemoteException

remove

public boolean remove(java.io.Serializable key)
               throws java.lang.IllegalStateException,
                      java.rmi.RemoteException

指定者:

remove 在接口中 com.fr.third.net.sf.ehcache.distribution.CachePeer

抛出:

java.lang.IllegalStateException

java.rmi.RemoteException

removeAll

public void removeAll()
               throws java.rmi.RemoteException,
                      java.lang.IllegalStateException

指定者:

removeAll 在接口中 com.fr.third.net.sf.ehcache.distribution.CachePeer

抛出:

java.rmi.RemoteException

java.lang.IllegalStateException