com.liferay.portal.cluster
Class ClusterLinkImpl

java.lang.Object
  extended by com.liferay.portal.cluster.ClusterLinkImpl
All Implemented Interfaces:
com.liferay.portal.kernel.cluster.ClusterLink

public class ClusterLinkImpl
extends java.lang.Object
implements com.liferay.portal.kernel.cluster.ClusterLink

View Source

Author:
Shuyang Zhou

Constructor Summary
ClusterLinkImpl()
           
 
Method Summary
 void afterPropertiesSet()
           
protected  org.jgroups.JChannel createChannel(int index, java.lang.String properties)
           
 void destory()
           
 java.util.List<com.liferay.portal.kernel.cluster.Address> getAddresses()
           
protected  org.jgroups.JChannel getChannel(com.liferay.portal.kernel.cluster.Priority priority)
           
protected  void initBindAddress()
           
protected  void initChannels()
           
protected  void initSystemProperties()
           
 void sendMulticastMessage(com.liferay.portal.kernel.messaging.Message message, com.liferay.portal.kernel.cluster.Priority priority)
           
 void sendUnicastMessage(com.liferay.portal.kernel.cluster.Address address, com.liferay.portal.kernel.messaging.Message message, com.liferay.portal.kernel.cluster.Priority priority)
           
 void setClusterForwardMessageListener(com.liferay.portal.kernel.cluster.messaging.ClusterForwardMessageListener clusterForwardMessageListener)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ClusterLinkImpl

public ClusterLinkImpl()
Method Detail

afterPropertiesSet

public void afterPropertiesSet()

destory

public void destory()

getAddresses

public java.util.List<com.liferay.portal.kernel.cluster.Address> getAddresses()
Specified by:
getAddresses in interface com.liferay.portal.kernel.cluster.ClusterLink

sendMulticastMessage

public void sendMulticastMessage(com.liferay.portal.kernel.messaging.Message message,
                                 com.liferay.portal.kernel.cluster.Priority priority)
Specified by:
sendMulticastMessage in interface com.liferay.portal.kernel.cluster.ClusterLink

sendUnicastMessage

public void sendUnicastMessage(com.liferay.portal.kernel.cluster.Address address,
                               com.liferay.portal.kernel.messaging.Message message,
                               com.liferay.portal.kernel.cluster.Priority priority)
Specified by:
sendUnicastMessage in interface com.liferay.portal.kernel.cluster.ClusterLink

setClusterForwardMessageListener

public void setClusterForwardMessageListener(com.liferay.portal.kernel.cluster.messaging.ClusterForwardMessageListener clusterForwardMessageListener)

createChannel

protected org.jgroups.JChannel createChannel(int index,
                                             java.lang.String properties)
                                      throws org.jgroups.ChannelException
Throws:
org.jgroups.ChannelException

getChannel

protected org.jgroups.JChannel getChannel(com.liferay.portal.kernel.cluster.Priority priority)

initBindAddress

protected void initBindAddress()
                        throws java.io.IOException
Throws:
java.io.IOException

initChannels

protected void initChannels()
                     throws org.jgroups.ChannelException
Throws:
org.jgroups.ChannelException

initSystemProperties

protected void initSystemProperties()