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(java.lang.String properties, org.jgroups.Receiver receiver, java.lang.String clusterName)
           
 void destroy()
           
protected  java.util.List<com.liferay.portal.kernel.cluster.Address> getAddresses(org.jgroups.JChannel channel)
           
protected  org.jgroups.JChannel getChannel(com.liferay.portal.kernel.cluster.Priority priority)
           
 java.util.List<com.liferay.portal.kernel.cluster.Address> getControlAddresses()
           
 com.liferay.portal.kernel.cluster.Address getLocalControlAddress()
           
 java.util.List<com.liferay.portal.kernel.cluster.Address> getLocalTransportAddresses()
           
 java.util.List<com.liferay.portal.kernel.cluster.Address> getTransportAddresses(com.liferay.portal.kernel.cluster.Priority priority)
           
protected  void initBindAddress()
           
protected  void initChannels()
           
protected  void initSystemProperties()
           
 boolean isEnabled()
           
 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()

destroy

public void destroy()

getControlAddresses

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

getLocalControlAddress

public com.liferay.portal.kernel.cluster.Address getLocalControlAddress()
Specified by:
getLocalControlAddress in interface com.liferay.portal.kernel.cluster.ClusterLink

getLocalTransportAddresses

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

getTransportAddresses

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

isEnabled

public boolean isEnabled()
Specified by:
isEnabled 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(java.lang.String properties,
                                             org.jgroups.Receiver receiver,
                                             java.lang.String clusterName)
                                      throws org.jgroups.ChannelException
Throws:
org.jgroups.ChannelException

getAddresses

protected java.util.List<com.liferay.portal.kernel.cluster.Address> getAddresses(org.jgroups.JChannel channel)

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()