com.liferay.portal.cluster
Class ClusterLinkImpl
java.lang.Object
com.liferay.portal.cluster.ClusterBase
com.liferay.portal.cluster.ClusterLinkImpl
- All Implemented Interfaces:
- com.liferay.portal.kernel.cluster.ClusterLink
public class ClusterLinkImpl
- extends ClusterBase
- implements com.liferay.portal.kernel.cluster.ClusterLink
View Source
- Author:
- Shuyang Zhou
Method Summary |
void |
destroy()
|
protected org.jgroups.JChannel |
getChannel(com.liferay.portal.kernel.cluster.Priority priority)
|
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 |
initChannels()
|
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 |
Methods inherited from interface com.liferay.portal.kernel.cluster.ClusterLink |
isEnabled |
ClusterLinkImpl
public ClusterLinkImpl()
destroy
public void destroy()
- Specified by:
destroy
in class ClusterBase
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
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)
getChannel
protected org.jgroups.JChannel getChannel(com.liferay.portal.kernel.cluster.Priority priority)
initChannels
protected void initChannels()
throws org.jgroups.ChannelException
- Specified by:
initChannels
in class ClusterBase
- Throws:
org.jgroups.ChannelException