public class ClusterExecutorImpl
extends java.lang.Object
implements com.liferay.portal.kernel.cluster.ClusterExecutor
| Modifier and Type | Field and Description |
|---|---|
protected ClusterExecutorConfiguration |
clusterExecutorConfiguration |
| Constructor and Description |
|---|
ClusterExecutorImpl() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
activate(org.osgi.service.component.ComponentContext componentContext) |
void |
addClusterEventListener(com.liferay.portal.kernel.cluster.ClusterEventListener clusterEventListener) |
protected void |
configurePortalInstanceCommunications() |
protected void |
deactivate() |
com.liferay.portal.kernel.cluster.FutureClusterResponses |
execute(com.liferay.portal.kernel.cluster.ClusterRequest clusterRequest) |
protected com.liferay.portal.kernel.cluster.ClusterNodeResponse |
executeClusterRequest(com.liferay.portal.kernel.cluster.ClusterRequest clusterRequest) |
protected void |
fireClusterEvent(com.liferay.portal.kernel.cluster.ClusterEvent clusterEvent) |
protected java.lang.String |
generateClusterNodeId() |
java.net.InetAddress |
getBindInetAddress() |
java.net.NetworkInterface |
getBindNetworkInterface() |
protected java.lang.String |
getChannelName(java.util.Dictionary<java.lang.String,java.lang.Object> properties) |
protected java.lang.String |
getChannelPropertiesString(java.util.Dictionary<java.lang.String,java.lang.Object> properties) |
protected ClusterChannel |
getClusterChannel() |
java.util.List<com.liferay.portal.kernel.cluster.ClusterEventListener> |
getClusterEventListeners() |
protected com.liferay.portal.kernel.cluster.ClusterNode |
getClusterNode(com.liferay.portal.kernel.cluster.Address address) |
java.util.List<com.liferay.portal.kernel.cluster.ClusterNode> |
getClusterNodes() |
protected java.net.InetSocketAddress |
getConfiguredPortalInetSocketAddress(com.liferay.portal.kernel.util.Props props) |
protected java.util.concurrent.ExecutorService |
getExecutorService() |
com.liferay.portal.kernel.cluster.ClusterNode |
getLocalClusterNode() |
protected void |
handleReceivedClusterNodeResponse(com.liferay.portal.kernel.cluster.ClusterNodeResponse clusterNodeResponse) |
protected java.io.Serializable |
handleReceivedClusterRequest(com.liferay.portal.kernel.cluster.ClusterRequest clusterRequest) |
protected void |
initialize(java.lang.String channelPropertiesString,
java.lang.String channelName) |
boolean |
isClusterNodeAlive(java.lang.String clusterNodeId) |
boolean |
isEnabled() |
protected void |
manageDebugClusterEventListener() |
protected boolean |
memberJoined(com.liferay.portal.cluster.multiple.internal.ClusterExecutorImpl.ClusterNodeStatus clusterNodeStatus) |
protected void |
memberRemoved(java.util.List<com.liferay.portal.kernel.cluster.Address> departAddresses) |
protected void |
modified(java.util.Map<java.lang.String,java.lang.Object> properties) |
void |
removeClusterEventListener(com.liferay.portal.kernel.cluster.ClusterEventListener clusterEventListener) |
protected void |
sendNotifyRequest() |
protected void |
setClusterChannelFactory(ClusterChannelFactory clusterChannelFactory) |
protected void |
setClusterEventListeners(java.util.List<com.liferay.portal.kernel.cluster.ClusterEventListener> clusterEventListeners) |
protected void |
setPortalExecutorManager(com.liferay.portal.kernel.executor.PortalExecutorManager portalExecutorManager) |
protected void |
setProps(com.liferay.portal.kernel.util.Props props) |
protected volatile ClusterExecutorConfiguration clusterExecutorConfiguration
public void addClusterEventListener(com.liferay.portal.kernel.cluster.ClusterEventListener clusterEventListener)
addClusterEventListener in interface com.liferay.portal.kernel.cluster.ClusterExecutorpublic com.liferay.portal.kernel.cluster.FutureClusterResponses execute(com.liferay.portal.kernel.cluster.ClusterRequest clusterRequest)
execute in interface com.liferay.portal.kernel.cluster.ClusterExecutorpublic java.net.InetAddress getBindInetAddress()
getBindInetAddress in interface com.liferay.portal.kernel.cluster.ClusterExecutorpublic java.net.NetworkInterface getBindNetworkInterface()
getBindNetworkInterface in interface com.liferay.portal.kernel.cluster.ClusterExecutorpublic java.util.List<com.liferay.portal.kernel.cluster.ClusterEventListener> getClusterEventListeners()
getClusterEventListeners in interface com.liferay.portal.kernel.cluster.ClusterExecutorpublic java.util.List<com.liferay.portal.kernel.cluster.ClusterNode> getClusterNodes()
getClusterNodes in interface com.liferay.portal.kernel.cluster.ClusterExecutorpublic com.liferay.portal.kernel.cluster.ClusterNode getLocalClusterNode()
getLocalClusterNode in interface com.liferay.portal.kernel.cluster.ClusterExecutorpublic boolean isClusterNodeAlive(java.lang.String clusterNodeId)
isClusterNodeAlive in interface com.liferay.portal.kernel.cluster.ClusterExecutorpublic boolean isEnabled()
isEnabled in interface com.liferay.portal.kernel.cluster.ClusterExecutorpublic void removeClusterEventListener(com.liferay.portal.kernel.cluster.ClusterEventListener clusterEventListener)
removeClusterEventListener in interface com.liferay.portal.kernel.cluster.ClusterExecutorprotected void activate(org.osgi.service.component.ComponentContext componentContext)
protected void configurePortalInstanceCommunications()
protected void deactivate()
protected com.liferay.portal.kernel.cluster.ClusterNodeResponse executeClusterRequest(com.liferay.portal.kernel.cluster.ClusterRequest clusterRequest)
protected void fireClusterEvent(com.liferay.portal.kernel.cluster.ClusterEvent clusterEvent)
protected java.lang.String generateClusterNodeId()
protected java.lang.String getChannelName(java.util.Dictionary<java.lang.String,java.lang.Object> properties)
protected java.lang.String getChannelPropertiesString(java.util.Dictionary<java.lang.String,java.lang.Object> properties)
protected ClusterChannel getClusterChannel()
protected com.liferay.portal.kernel.cluster.ClusterNode getClusterNode(com.liferay.portal.kernel.cluster.Address address)
protected java.net.InetSocketAddress getConfiguredPortalInetSocketAddress(com.liferay.portal.kernel.util.Props props)
protected java.util.concurrent.ExecutorService getExecutorService()
protected void handleReceivedClusterNodeResponse(com.liferay.portal.kernel.cluster.ClusterNodeResponse clusterNodeResponse)
protected java.io.Serializable handleReceivedClusterRequest(com.liferay.portal.kernel.cluster.ClusterRequest clusterRequest)
protected void initialize(java.lang.String channelPropertiesString,
java.lang.String channelName)
protected void manageDebugClusterEventListener()
protected boolean memberJoined(com.liferay.portal.cluster.multiple.internal.ClusterExecutorImpl.ClusterNodeStatus clusterNodeStatus)
protected void memberRemoved(java.util.List<com.liferay.portal.kernel.cluster.Address> departAddresses)
protected void modified(java.util.Map<java.lang.String,java.lang.Object> properties)
protected void sendNotifyRequest()
protected void setClusterChannelFactory(ClusterChannelFactory clusterChannelFactory)
protected void setClusterEventListeners(java.util.List<com.liferay.portal.kernel.cluster.ClusterEventListener> clusterEventListeners)
protected void setPortalExecutorManager(com.liferay.portal.kernel.executor.PortalExecutorManager portalExecutorManager)
protected void setProps(com.liferay.portal.kernel.util.Props props)