com.liferay.portal.cluster
Class ClusterLinkImpl
java.lang.Object
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
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
ClusterLinkImpl
public ClusterLinkImpl()
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()