com.liferay.portal.cluster
Class ClusterLinkImpl

java.lang.Object
  com.liferay.portal.cluster.ClusterBase
      com.liferay.portal.cluster.ClusterLinkImpl

All Implemented Interfaces:

ClusterLink

public class ClusterLinkImpl
extends ClusterBase
implements ClusterLink

Field Summary

Fields inherited from class com.liferay.portal.cluster.ClusterBase

bindInetAddress

Fields inherited from interface com.liferay.portal.kernel.cluster.ClusterLink

CLUSTER_FORWARD_MESSAGE, MAX_CHANNEL_COUNT

Constructor Summary

ClusterLinkImpl()

Method Summary

void	destroy()
InetAddress	getBindInetAddress()
protected org.jgroups.JChannel	getChannel(Priority priority)
List<Address>	getLocalTransportAddresses()
List<Address>	getTransportAddresses(Priority priority)
protected void	initChannels()
void	initialize()
void	sendMulticastMessage(Message message, Priority priority)
void	sendUnicastMessage(Address address, Message message, Priority priority)
void	setClusterForwardMessageListener(ClusterForwardMessageListener clusterForwardMessageListener)

Methods inherited from class com.liferay.portal.cluster.ClusterBase

afterPropertiesSet, createJChannel, getAddresses, initBindAddress, initSystemProperties, isEnabled, sendJGroupsMessage

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

Constructor Detail

ClusterLinkImpl

public ClusterLinkImpl()

Method Detail

destroy

public void destroy()

Specified by:

destroy in class ClusterBase

getBindInetAddress

public InetAddress getBindInetAddress()

Specified by:

getBindInetAddress in interface ClusterLink

getLocalTransportAddresses

public List<Address> getLocalTransportAddresses()

Specified by:

getLocalTransportAddresses in interface ClusterLink

getTransportAddresses

public List<Address> getTransportAddresses(Priority priority)

Specified by:

getTransportAddresses in interface ClusterLink

initialize

public void initialize()

Specified by:

initialize in interface ClusterLink

sendMulticastMessage

public void sendMulticastMessage(Message message,
                                 Priority priority)

Specified by:

sendMulticastMessage in interface ClusterLink

sendUnicastMessage

public void sendUnicastMessage(Address address,
                               Message message,
                               Priority priority)

Specified by:

sendUnicastMessage in interface ClusterLink

setClusterForwardMessageListener

public void setClusterForwardMessageListener(ClusterForwardMessageListener clusterForwardMessageListener)

getChannel

protected org.jgroups.JChannel getChannel(Priority priority)

initChannels

protected void initChannels()
                     throws Exception

Specified by:

initChannels in class ClusterBase

Throws:

Exception