Package de.aristaflow.adept2.core.registry.cluster

Interface ClusterCommPoller

All Known Implementing Classes:

ClusterNode

public interface ClusterCommPoller

Interface for polling a cluster node via communication.

Method Summary

Modifier and Type	Method	Description
URI[]	getServerCommService()	Gets the URIs of the cluster service of the server for inter node communication.
void	pollServerComm(long timeout, boolean serverDoubtful)	Polls the server of this cluster via communication.

Method Details

getServerCommService

URI[] getServerCommService()

Gets the URIs of the cluster service of the server for inter node communication.

Returns:

The URIs of the cluster service of the server for inter node communication or null if no global registry URIs are set.

pollServerComm

void pollServerComm(long timeout,
 boolean serverDoubtful)
             throws InterruptedException

Polls the server of this cluster via communication. If the server cannot be reached via communication, the corresponding lost count will be increased. Afterwards the cluster heartbeat using the database will be notified. It will also be notified if the state of the server changes.

If the control of the cluster node cannot be acquired in the designated time, this method will do nothing.

Parameters:

timeout - The time in milliseconds to wait for the cluster control lock.

serverDoubtful - Whether the server is doubtful and should be notified appropriately.

Throws:

InterruptedException - If the calling thread is interrupted while waiting for the node control or has been interrupted before, an InterruptedException will be thrown.