public abstract class BaseClusterReceiver extends java.lang.Object implements ClusterReceiver
| Constructor and Description |
|---|
BaseClusterReceiver(java.util.concurrent.ExecutorService executorService) |
| Modifier and Type | Method and Description |
|---|---|
void |
addressesUpdated(java.util.List<com.liferay.portal.kernel.cluster.Address> addresses) |
void |
coordinatorAddressUpdated(com.liferay.portal.kernel.cluster.Address coordinatorAddress) |
protected void |
doAddressesUpdated(java.util.List<com.liferay.portal.kernel.cluster.Address> oldAddresses,
java.util.List<com.liferay.portal.kernel.cluster.Address> newAddresses) |
protected void |
doCoordinatorAddressUpdated(com.liferay.portal.kernel.cluster.Address oldCoordinatorAddress,
com.liferay.portal.kernel.cluster.Address newCoordinatorAddress) |
protected abstract void |
doReceive(java.lang.Object messagePayload,
com.liferay.portal.kernel.cluster.Address srcAddress) |
java.util.List<com.liferay.portal.kernel.cluster.Address> |
getAddresses() |
com.liferay.portal.kernel.cluster.Address |
getCoordinatorAddress() |
void |
openLatch() |
void |
receive(java.lang.Object messagePayload,
com.liferay.portal.kernel.cluster.Address srcAddress) |
public BaseClusterReceiver(java.util.concurrent.ExecutorService executorService)
public void addressesUpdated(java.util.List<com.liferay.portal.kernel.cluster.Address> addresses)
addressesUpdated in interface ClusterReceiverpublic void coordinatorAddressUpdated(com.liferay.portal.kernel.cluster.Address coordinatorAddress)
coordinatorAddressUpdated in interface ClusterReceiverpublic java.util.List<com.liferay.portal.kernel.cluster.Address> getAddresses()
getAddresses in interface ClusterReceiverpublic com.liferay.portal.kernel.cluster.Address getCoordinatorAddress()
getCoordinatorAddress in interface ClusterReceiverpublic void openLatch()
openLatch in interface ClusterReceiverpublic void receive(java.lang.Object messagePayload,
com.liferay.portal.kernel.cluster.Address srcAddress)
receive in interface ClusterReceiverprotected void doAddressesUpdated(java.util.List<com.liferay.portal.kernel.cluster.Address> oldAddresses,
java.util.List<com.liferay.portal.kernel.cluster.Address> newAddresses)
protected void doCoordinatorAddressUpdated(com.liferay.portal.kernel.cluster.Address oldCoordinatorAddress,
com.liferay.portal.kernel.cluster.Address newCoordinatorAddress)
protected abstract void doReceive(java.lang.Object messagePayload,
com.liferay.portal.kernel.cluster.Address srcAddress)