Package org.elasticsearch.common.logging

Class NodeAndClusterIdStateListener

org.elasticsearch.common.logging.NodeAndClusterIdStateListener

All Implemented Interfaces:

ClusterStateObserver.Listener

public class NodeAndClusterIdStateListener
extends 
implements ClusterStateObserver.Listener

The NodeAndClusterIdStateListener listens to cluster state changes and ONLY when receives the first update it sets the clusterUUID and nodeID in log4j pattern converter NodeAndClusterIdConverter. Once the first update is received, it will automatically be de-registered from subsequent updates.

Method Summary

Modifier and Type	Method	Description
static void	getAndSetNodeIdAndClusterId(ClusterService clusterService, ThreadContext threadContext)	Subscribes for the first cluster state update where nodeId and clusterId is present and sets these values in NodeAndClusterIdConverter.
void	onClusterServiceClose()	called when the cluster service is closed
void	onNewClusterState(ClusterState state)	called when a new state is observed
void	onTimeout(org.elasticsearch.core.TimeValue timeout)

Methods inherited from class java.lang.

, , , , , , , , , ,

Method Details

getAndSetNodeIdAndClusterId

public static void getAndSetNodeIdAndClusterId(ClusterService clusterService,
 ThreadContext threadContext)

Subscribes for the first cluster state update where nodeId and clusterId is present and sets these values in NodeAndClusterIdConverter.

onNewClusterState

public void onNewClusterState(ClusterState state)

Description copied from interface: ClusterStateObserver.Listener

called when a new state is observed

Specified by:

onNewClusterState in interface ClusterStateObserver.Listener

onClusterServiceClose

public void onClusterServiceClose()

Description copied from interface: ClusterStateObserver.Listener

called when the cluster service is closed

Specified by:

onClusterServiceClose in interface ClusterStateObserver.Listener

onTimeout

public void onTimeout(org.elasticsearch.core.TimeValue timeout)

Specified by:

onTimeout in interface ClusterStateObserver.Listener