001
014
015 package com.liferay.portal.kernel.cluster;
016
017 import com.liferay.portal.kernel.exception.SystemException;
018
019 import java.util.List;
020 import java.util.concurrent.TimeUnit;
021
022
025 public interface ClusterExecutor {
026
027 public void addClusterEventListener(
028 ClusterEventListener clusterEventListener);
029
030 public void destroy();
031
032 public FutureClusterResponses execute(ClusterRequest clusterRequest)
033 throws SystemException;
034
035 public void execute(
036 ClusterRequest clusterRequest,
037 ClusterResponseCallback clusterResponseCallback)
038 throws SystemException;
039
040 public void execute(
041 ClusterRequest clusterRequest,
042 ClusterResponseCallback clusterResponseCallback, long timeout,
043 TimeUnit timeUnit)
044 throws SystemException;
045
046 public List<ClusterEventListener> getClusterEventListeners();
047
048 public List<Address> getClusterNodeAddresses();
049
050 public Address getCoordinatorAddress();
051
052 public List<ClusterNode> getClusterNodes();
053
054 public ClusterNode getLocalClusterNode() throws SystemException;
055
056 public Address getLocalClusterNodeAddress();
057
058 public void initialize();
059
060 public boolean isClusterNodeAlive(Address address);
061
062 public boolean isClusterNodeAlive(String clusterNodeId);
063
064 public boolean isEnabled();
065
066 public void removeClusterEventListener(
067 ClusterEventListener clusterEventListener);
068
069 }