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

static int

MAX_CHANNEL_COUNT

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

bindInetAddress

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

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

Field Detail

MAX_CHANNEL_COUNT

public static final int MAX_CHANNEL_COUNT

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

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 org.jgroups.ChannelException

Specified by:

initChannels in class ClusterBase

Throws:

org.jgroups.ChannelException