public class ClusterLinkImpl
extends java.lang.Object
implements com.liferay.portal.kernel.cluster.ClusterLink
| Constructor and Description |
|---|
ClusterLinkImpl() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
activate(java.util.Map<java.lang.String,java.lang.Object> properties) |
protected void |
deactivate() |
protected ClusterChannel |
getChannel(com.liferay.portal.kernel.cluster.Priority priority) |
protected java.util.Map<java.lang.String,java.lang.String> |
getChannelNames(java.util.Map<java.lang.String,java.lang.Object> properties) |
protected java.util.Map<java.lang.String,java.lang.String> |
getChannelPropertiesStrings(java.util.Map<java.lang.String,java.lang.Object> properties) |
protected java.util.concurrent.ExecutorService |
getExecutorService() |
protected java.util.List<com.liferay.portal.kernel.cluster.Address> |
getLocalAddresses() |
protected void |
initChannels(java.util.Map<java.lang.String,java.lang.String> channelPropertiesStrings,
java.util.Map<java.lang.String,java.lang.String> channelNames) |
protected void |
initialize(java.util.Map<java.lang.String,java.lang.String> channelPropertiesStrings,
java.util.Map<java.lang.String,java.lang.String> channelNames) |
boolean |
isEnabled() |
protected void |
sendLocalMessage(com.liferay.portal.kernel.messaging.Message message) |
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) |
protected void |
setClusterChannelFactory(ClusterChannelFactory clusterChannelFactory) |
protected void |
setMessageBus(com.liferay.portal.kernel.messaging.MessageBus messageBus) |
protected void |
setPortalExecutorManager(com.liferay.portal.kernel.executor.PortalExecutorManager portalExecutorManager) |
protected void |
setProps(com.liferay.portal.kernel.util.Props props) |
protected void |
unsetMessageBus(com.liferay.portal.kernel.messaging.MessageBus messageBus) |
public boolean isEnabled()
isEnabled in interface com.liferay.portal.kernel.cluster.ClusterLinkpublic void sendMulticastMessage(com.liferay.portal.kernel.messaging.Message message,
com.liferay.portal.kernel.cluster.Priority priority)
sendMulticastMessage in interface com.liferay.portal.kernel.cluster.ClusterLinkpublic void sendUnicastMessage(com.liferay.portal.kernel.cluster.Address address,
com.liferay.portal.kernel.messaging.Message message,
com.liferay.portal.kernel.cluster.Priority priority)
sendUnicastMessage in interface com.liferay.portal.kernel.cluster.ClusterLinkprotected void activate(java.util.Map<java.lang.String,java.lang.Object> properties)
protected void deactivate()
protected ClusterChannel getChannel(com.liferay.portal.kernel.cluster.Priority priority)
protected java.util.Map<java.lang.String,java.lang.String> getChannelNames(java.util.Map<java.lang.String,java.lang.Object> properties)
protected java.util.Map<java.lang.String,java.lang.String> getChannelPropertiesStrings(java.util.Map<java.lang.String,java.lang.Object> properties)
protected java.util.concurrent.ExecutorService getExecutorService()
protected java.util.List<com.liferay.portal.kernel.cluster.Address> getLocalAddresses()
protected void initChannels(java.util.Map<java.lang.String,java.lang.String> channelPropertiesStrings,
java.util.Map<java.lang.String,java.lang.String> channelNames)
throws java.lang.Exception
java.lang.Exceptionprotected void initialize(java.util.Map<java.lang.String,java.lang.String> channelPropertiesStrings,
java.util.Map<java.lang.String,java.lang.String> channelNames)
protected void sendLocalMessage(com.liferay.portal.kernel.messaging.Message message)
protected void setClusterChannelFactory(ClusterChannelFactory clusterChannelFactory)
protected void setMessageBus(com.liferay.portal.kernel.messaging.MessageBus messageBus)
protected void setPortalExecutorManager(com.liferay.portal.kernel.executor.PortalExecutorManager portalExecutorManager)
protected void setProps(com.liferay.portal.kernel.util.Props props)
protected void unsetMessageBus(com.liferay.portal.kernel.messaging.MessageBus messageBus)